Skip to content

Commit 1f03b60

Browse files
author
Andrew Or
committed
Synchronize kills
1 parent ab8177d commit 1f03b60

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -334,7 +334,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val actorSyste
334334
* Request that the cluster manager kill the specified executors.
335335
* Return whether the kill request is acknowledged.
336336
*/
337-
final def killExecutors(executorIds: Seq[String]): Boolean = {
337+
final def killExecutors(executorIds: Seq[String]): Boolean = synchronized {
338338
logInfo(s"Requesting to kill executor(s) ${executorIds.mkString(", ")}")
339339
val filteredExecutorIds = new ArrayBuffer[String]
340340
executorIds.foreach { id =>

0 commit comments

Comments
 (0)