Skip to content

Commit 7ecf30e

Browse files
Andrew OrJoshRosen
authored andcommitted
[SPARK-4750] Dynamic allocation - synchronize kills
Simple omission on my part. Author: Andrew Or <[email protected]> Closes #3612 from andrewor14/dynamic-allocation-synchronization and squashes the following commits: 1f03b60 [Andrew Or] Synchronize kills (cherry picked from commit 65f929d) Signed-off-by: Josh Rosen <[email protected]>
1 parent e1d839e commit 7ecf30e

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)