Don't try to return a value from DAGScheduler.runJob

markhamstra · markhamstra · commit 4e5860db44df · 2013-07-02T09:17:27.000-07:00
diff --git a/core/src/main/scala/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/spark/scheduler/DAGScheduler.scala
@@ -264,7 +264,6 @@ class DAGScheduler(
         logInfo("Failed to run " + callSite)
         throw exception
     }
-    r
   }
 
   def runApproximateJob[T, U, R](

Original file line number	Diff line number	Diff line change
`@@ -264,7 +264,6 @@ class DAGScheduler(`
`264`	`264`	`logInfo("Failed to run " + callSite)`
`265`	`265`	`throw exception`
`266`	`266`	`}`
`267`		`- r`
`268`	`267`	`}`
`269`	`268`
`270`	`269`	`def runApproximateJob[T, U, R](`