File tree Expand file tree Collapse file tree 1 file changed +5
-10
lines changed
resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn Expand file tree Collapse file tree 1 file changed +5
-10
lines changed Original file line number Diff line number Diff line change @@ -583,17 +583,12 @@ private[spark] class ApplicationMaster(
583583 allocator.allocateResources()
584584 }
585585 } else {
586- if (allocator.isAllNodeExcluded) {
587- finish(FinalApplicationStatus .FAILED ,
588- ApplicationMaster .EXIT_MAX_EXECUTOR_FAILURES ,
589- " Due to executor failures all available nodes are excluded" )
590- } else {
591- if (allocator.getNumExecutorsFailed >= maxNumExecutorFailures) {
592- logError(s " Max number of executor failures ( $maxNumExecutorFailures) reached " )
593- }
594- logDebug(" Sending progress" )
595- allocator.allocateResources()
586+ // allocator.isAllNodeExcluded may be true if failing over RM, so we should not exit here
587+ if (allocator.getNumExecutorsFailed >= maxNumExecutorFailures) {
588+ logError(s " Max number of executor failures ( $maxNumExecutorFailures) reached " )
596589 }
590+ logDebug(" Sending progress" )
591+ allocator.allocateResources()
597592 }
598593 failureCount = 0
599594 } catch {
You can’t perform that action at this time.
0 commit comments