diff options
| author | Andrew Or <andrew@databricks.com> | 2014-12-08 16:02:33 -0800 |
|---|---|---|
| committer | Josh Rosen <joshrosen@databricks.com> | 2014-12-08 16:02:33 -0800 |
| commit | 65f929d5b3a50a73cd6397bd4b72c3e7d94c99d7 (patch) | |
| tree | 2ea9f718e5caafed2ba5077ed2cdc696862457e4 /core | |
| parent | d6a972b3e4dc35a2d95df47d256462b325f4bda6 (diff) | |
| download | spark-65f929d5b3a50a73cd6397bd4b72c3e7d94c99d7.tar.gz spark-65f929d5b3a50a73cd6397bd4b72c3e7d94c99d7.tar.bz2 spark-65f929d5b3a50a73cd6397bd4b72c3e7d94c99d7.zip | |
[SPARK-4750] Dynamic allocation - synchronize kills
Simple omission on my part.
Author: Andrew Or <andrew@databricks.com>
Closes #3612 from andrewor14/dynamic-allocation-synchronization and squashes the following commits:
1f03b60 [Andrew Or] Synchronize kills
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala index 88b196ac64..29cd34429b 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala @@ -334,7 +334,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val actorSyste * Request that the cluster manager kill the specified executors. * Return whether the kill request is acknowledged. */ - final def killExecutors(executorIds: Seq[String]): Boolean = { + final def killExecutors(executorIds: Seq[String]): Boolean = synchronized { logInfo(s"Requesting to kill executor(s) ${executorIds.mkString(", ")}") val filteredExecutorIds = new ArrayBuffer[String] executorIds.foreach { id => |