Repository: spark Updated Branches: refs/heads/master 8867cd0bc -> 9c249743e
[SPARK-2154] Schedule next Driver when one completes (standalone mode) Author: Aaron Davidson <[email protected]> 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 <[email protected]> Authored: Wed Jul 16 14:16:48 2014 -0700 Committer: Patrick Wendell <[email protected]> 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") }
