@@ -104,7 +104,7 @@ private[spark] class Master(
104
104
105
105
var leaderElectionAgent : ActorRef = _
106
106
107
- private var recoverCallable : Cancellable = _
107
+ private var recoveryCompletionTask : Cancellable = _
108
108
109
109
// As a temporary workaround before better ways of configuring memory, we allow users to set
110
110
// a flag that will perform round-robin scheduling across the nodes (spreading out each app
@@ -155,8 +155,8 @@ private[spark] class Master(
155
155
156
156
override def postStop () {
157
157
// prevent the CompleteRecovery message sending to restarted master
158
- if (recoverCallable != null ) {
159
- recoverCallable .cancel()
158
+ if (recoveryCompletionTask != null ) {
159
+ recoveryCompletionTask .cancel()
160
160
}
161
161
webUi.stop()
162
162
fileSystemsUsed.foreach(_.close())
@@ -177,7 +177,7 @@ private[spark] class Master(
177
177
logInfo(" I have been elected leader! New state: " + state)
178
178
if (state == RecoveryState .RECOVERING ) {
179
179
beginRecovery(storedApps, storedDrivers, storedWorkers)
180
- recoverCallable = context.system.scheduler.scheduleOnce(WORKER_TIMEOUT millis, self,
180
+ recoveryCompletionTask = context.system.scheduler.scheduleOnce(WORKER_TIMEOUT millis, self,
181
181
CompleteRecovery )
182
182
}
183
183
}
0 commit comments