Skip to content

Commit c7e969a

Browse files
committed
fix
1 parent 9657575 commit c7e969a

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -646,6 +646,8 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
646646

647647
val killExecutors: Boolean => Future[Boolean] =
648648
if (!executorsToKill.isEmpty) {
649+
executorsToKill.foreach(id =>
650+
executorDataMap.get(id).foreach(_.executorEndpoint.send(StopExecutor)))
649651
_ => doKillExecutors(executorsToKill)
650652
} else {
651653
_ => Future.successful(false)

0 commit comments

Comments
 (0)