Updated Branches: refs/heads/master 951024fee -> aadeda5e7
Removed unused return value in SparkContext.runJob Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/a0c45651 Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/a0c45651 Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/a0c45651 Branch: refs/heads/master Commit: a0c4565183b1dcfa816f280ddf9c60c4c117df06 Parents: bf4e613 Author: Lian, Cheng <[email protected]> Authored: Wed Nov 6 23:18:59 2013 +0800 Committer: Lian, Cheng <[email protected]> Committed: Wed Nov 6 23:18:59 2013 +0800 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/SparkContext.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/a0c45651/core/src/main/scala/org/apache/spark/SparkContext.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala index 880b49e..2bfe7c7 100644 --- a/core/src/main/scala/org/apache/spark/SparkContext.scala +++ b/core/src/main/scala/org/apache/spark/SparkContext.scala @@ -796,11 +796,10 @@ class SparkContext( val cleanedFunc = clean(func) logInfo("Starting job: " + callSite) val start = System.nanoTime - val result = dagScheduler.runJob(rdd, cleanedFunc, partitions, callSite, allowLocal, + dagScheduler.runJob(rdd, cleanedFunc, partitions, callSite, allowLocal, resultHandler, localProperties.get) logInfo("Job finished: " + callSite + ", took " + (System.nanoTime - start) / 1e9 + " s") rdd.doCheckpoint() - result } /**
