YARN-4424. Fix deadlock in RMAppImpl. (Jian he via wangda)
(cherry picked from commit 7e4715186d
)
Conflicts:
hadoop-yarn-project/CHANGES.txt
This commit is contained in:
parent
417fbf2dca
commit
7013f9d6cd
|
@ -1983,6 +1983,8 @@ Release 2.6.3 - UNRELEASED
|
||||||
YARN-4365. FileSystemNodeLabelStore should check for root dir existence on
|
YARN-4365. FileSystemNodeLabelStore should check for root dir existence on
|
||||||
startup (Kuhu Shukla via jlowe)
|
startup (Kuhu Shukla via jlowe)
|
||||||
|
|
||||||
|
YARN-4424. Fix deadlock in RMAppImpl. (Jian he via wangda)
|
||||||
|
|
||||||
Release 2.6.2 - 2015-10-28
|
Release 2.6.2 - 2015-10-28
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -490,21 +490,15 @@ public class RMAppImpl implements RMApp, Recoverable {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public FinalApplicationStatus getFinalApplicationStatus() {
|
public FinalApplicationStatus getFinalApplicationStatus() {
|
||||||
this.readLock.lock();
|
// finish state is obtained based on the state machine's current state
|
||||||
try {
|
// as a fall-back in case the application has not been unregistered
|
||||||
// finish state is obtained based on the state machine's current state
|
// ( or if the app never unregistered itself )
|
||||||
// as a fall-back in case the application has not been unregistered
|
// when the report is requested
|
||||||
// ( or if the app never unregistered itself )
|
if (currentAttempt != null
|
||||||
// when the report is requested
|
&& currentAttempt.getFinalApplicationStatus() != null) {
|
||||||
if (currentAttempt != null
|
return currentAttempt.getFinalApplicationStatus();
|
||||||
&& currentAttempt.getFinalApplicationStatus() != null) {
|
|
||||||
return currentAttempt.getFinalApplicationStatus();
|
|
||||||
}
|
|
||||||
return
|
|
||||||
createFinalApplicationStatus(this.stateMachine.getCurrentState());
|
|
||||||
} finally {
|
|
||||||
this.readLock.unlock();
|
|
||||||
}
|
}
|
||||||
|
return createFinalApplicationStatus(this.stateMachine.getCurrentState());
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
Loading…
Reference in New Issue