Skip to content

Commit b90ded8

Browse files
committed
Add comment.
1 parent 6fe96e5 commit b90ded8

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosCoarseGrainedSchedulerBackend.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -552,6 +552,9 @@ private[spark] class MesosCoarseGrainedSchedulerBackend(
552552
taskId: String,
553553
reason: String): Unit = {
554554
stateLock.synchronized {
555+
// Do not call removeExecutor() after this scheduler backend was stopped because
556+
// removeExecutor() internally will send a message to the driver endpoint but
557+
// the driver endpoint is not available now, otherwise an exception will be thrown.
555558
if (!stopCalled) {
556559
removeExecutor(taskId, SlaveLost(reason))
557560
}

0 commit comments

Comments
 (0)