diff --git a/core/src/main/scala/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/spark/scheduler/DAGScheduler.scala index 1c91fd0aed2c1..f9c880558eb15 100644 --- 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](