small fix

CodingCat · CodingCat · commit cd02d9a12c27 · 2014-04-23T18:57:06.000-04:00
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -433,7 +433,7 @@ class DAGScheduler(
   {
     val waiter = submitJob(rdd, func, partitions, callSite, allowLocal, resultHandler, properties)
     waiter.awaitResult() match {
-      case JobSucceeded =>
+      case JobSucceeded => {}
       case JobFailed(exception: Exception) =>
         logInfo("Failed to run " + callSite)
         throw exception

Original file line number	Diff line number	Diff line change
`@@ -433,7 +433,7 @@ class DAGScheduler(`
`433`	`433`	`{`
`434`	`434`	`val waiter = submitJob(rdd, func, partitions, callSite, allowLocal, resultHandler, properties)`
`435`	`435`	`waiter.awaitResult() match {`
`436`		`- case JobSucceeded =>`
	`436`	`+ case JobSucceeded => {}`
`437`	`437`	`case JobFailed(exception: Exception) =>`
`438`	`438`	`logInfo("Failed to run " + callSite)`
`439`	`439`	`throw exception`