You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by jo...@apache.org on 2014/12/09 01:02:43 UTC
spark git commit: [SPARK-4750] Dynamic allocation - synchronize kills
Repository: spark
Updated Branches:
refs/heads/master d6a972b3e -> 65f929d5b
[SPARK-4750] Dynamic allocation - synchronize kills
Simple omission on my part.
Author: Andrew Or <an...@databricks.com>
Closes #3612 from andrewor14/dynamic-allocation-synchronization and squashes the following commits:
1f03b60 [Andrew Or] Synchronize kills
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/65f929d5
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/65f929d5
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/65f929d5
Branch: refs/heads/master
Commit: 65f929d5b3a50a73cd6397bd4b72c3e7d94c99d7
Parents: d6a972b
Author: Andrew Or <an...@databricks.com>
Authored: Mon Dec 8 16:02:33 2014 -0800
Committer: Josh Rosen <jo...@databricks.com>
Committed: Mon Dec 8 16:02:33 2014 -0800
----------------------------------------------------------------------
.../spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/65f929d5/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala
----------------------------------------------------------------------
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 88b196a..29cd344 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 =>
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org