Skip to content

Commit a46e015

Browse files
committed
Update comment
1 parent 5d2fc40 commit a46e015

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -181,8 +181,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
181181
case RemoveExecutor(executorId, reason) =>
182182
// We will remove the executor's state and cannot restore it. However, the connection
183183
// between the driver and the executor may be still alive so that the executor won't exit
184-
// automatically (E.g., Master will send RemoveExecutor when a work is lost but the executor
185-
// is still alive), so try to tell the executor to stop itself. See SPARK-13519.
184+
// automatically, so try to tell the executor to stop itself. See SPARK-13519.
186185
executorDataMap.get(executorId).foreach(_.executorEndpoint.send(StopExecutor))
187186
removeExecutor(executorId, reason)
188187
context.reply(true)

0 commit comments

Comments
 (0)