You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/07/16 23:16:52 UTC
git commit: [SPARK-2154] Schedule next Driver when one completes
(standalone mode)
Repository: spark
Updated Branches:
refs/heads/master 8867cd0bc -> 9c249743e
[SPARK-2154] Schedule next Driver when one completes (standalone mode)
Author: Aaron Davidson <aa...@databricks.com>
Closes #1405 from aarondav/2154 and squashes the following commits:
24e9ef9 [Aaron Davidson] [SPARK-2154] Schedule next Driver when one completes (standalone mode)
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/9c249743
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/9c249743
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/9c249743
Branch: refs/heads/master
Commit: 9c249743eaabe5fc8d961c7aa581cc0197f6e950
Parents: 8867cd0
Author: Aaron Davidson <aa...@databricks.com>
Authored: Wed Jul 16 14:16:48 2014 -0700
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Wed Jul 16 14:16:48 2014 -0700
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/deploy/master/Master.scala | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/9c249743/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/deploy/master/Master.scala b/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
index 9fa556d..0b2d9db 100644
--- a/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
+++ b/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
@@ -751,6 +751,7 @@ private[spark] class Master(
driver.state = finalState
driver.exception = exception
driver.worker.foreach(w => w.removeDriver(driver))
+ schedule()
case None =>
logWarning(s"Asked to remove unknown driver: $driverId")
}