We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b2b7b25 commit f099c0bCopy full SHA for f099c0b
core/src/main/scala/org/apache/spark/deploy/master/Master.scala
@@ -312,7 +312,7 @@ private[spark] class Master(
312
if (appInfo.incrementRetryCount() < ApplicationState.MAX_NUM_RETRY) {
313
schedule()
314
} else {
315
- val execs = idToApp(appId).executors.values
+ val execs = appInfo.executors.values
316
if (!execs.exists(_.state == ExecutorState.RUNNING)) {
317
logError(s"Application ${appInfo.desc.name} with ID ${appInfo.id} failed " +
318
s"${appInfo.retryCount} times; removing it")
0 commit comments