Persist submitted driver.

tnachen · tnachen · commit e24b512b4139 · 2015-04-21T17:39:47.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterScheduler.scala
@@ -154,6 +154,7 @@ private[spark] class MesosClusterScheduler(
         return c
       }
       c.submissionId = desc.submissionId
+      queuedDriversState.persist(desc.submissionId, desc)
       queuedDrivers += desc
       c.success = true
     }

Original file line number	Diff line number	Diff line change
`@@ -154,6 +154,7 @@ private[spark] class MesosClusterScheduler(`
`154`	`154`	`return c`
`155`	`155`	`}`
`156`	`156`	`c.submissionId = desc.submissionId`
	`157`	`+ queuedDriversState.persist(desc.submissionId, desc)`
`157`	`158`	`queuedDrivers += desc`
`158`	`159`	`c.success = true`
`159`	`160`	`}`