@@ -104,7 +104,7 @@ private[spark] class Master(
104104
105105 var leaderElectionAgent : ActorRef = _
106106
107- private var recoverCallable : Cancellable = _
107+ private var recoveryCompletionTask : Cancellable = _
108108
109109 // As a temporary workaround before better ways of configuring memory, we allow users to set
110110 // a flag that will perform round-robin scheduling across the nodes (spreading out each app
@@ -155,8 +155,8 @@ private[spark] class Master(
155155
156156 override def postStop () {
157157 // prevent the CompleteRecovery message sending to restarted master
158- if (recoverCallable != null ) {
159- recoverCallable .cancel()
158+ if (recoveryCompletionTask != null ) {
159+ recoveryCompletionTask .cancel()
160160 }
161161 webUi.stop()
162162 fileSystemsUsed.foreach(_.close())
@@ -177,7 +177,7 @@ private[spark] class Master(
177177 logInfo(" I have been elected leader! New state: " + state)
178178 if (state == RecoveryState .RECOVERING ) {
179179 beginRecovery(storedApps, storedDrivers, storedWorkers)
180- recoverCallable = context.system.scheduler.scheduleOnce(WORKER_TIMEOUT millis, self,
180+ recoveryCompletionTask = context.system.scheduler.scheduleOnce(WORKER_TIMEOUT millis, self,
181181 CompleteRecovery )
182182 }
183183 }
0 commit comments