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 36a2ac0 commit 69e0a2aCopy full SHA for 69e0a2a
core/src/main/scala/org/apache/spark/deploy/master/Master.scala
@@ -177,7 +177,8 @@ private[spark] class Master(
177
logInfo("I have been elected leader! New state: " + state)
178
if (state == RecoveryState.RECOVERING) {
179
beginRecovery(storedApps, storedDrivers, storedWorkers)
180
- recoverCallable = context.system.scheduler.scheduleOnce(WORKER_TIMEOUT millis, self, CompleteRecovery)
+ recoverCallable = context.system.scheduler.scheduleOnce(WORKER_TIMEOUT millis, self,
181
+ CompleteRecovery)
182
}
183
184
0 commit comments