diff options
| author | Mingfei <mingfei.shi@intel.com> | 2013-06-21 18:21:35 +0800 |
|---|---|---|
| committer | Mingfei <mingfei.shi@intel.com> | 2013-06-21 18:21:35 +0800 |
| commit | 2fc794a6c7f1b86e5c0103a9c82af2be7fafb347 (patch) | |
| tree | 930020e44cdbcb09b719d8d188d06bc1bfbbf680 /core/src | |
| parent | 4b9862ac9cf2d00c5245e9a8b0fcb05b82030c98 (diff) | |
| download | spark-2fc794a6c7f1b86e5c0103a9c82af2be7fafb347.tar.gz spark-2fc794a6c7f1b86e5c0103a9c82af2be7fafb347.tar.bz2 spark-2fc794a6c7f1b86e5c0103a9c82af2be7fafb347.zip | |
small modify in DAGScheduler
Diffstat (limited to 'core/src')
| -rw-r--r-- | core/src/main/scala/spark/scheduler/DAGScheduler.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/spark/scheduler/DAGScheduler.scala index e412baa803..f7d60be5db 100644 --- a/core/src/main/scala/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/spark/scheduler/DAGScheduler.scala @@ -289,7 +289,6 @@ class DAGScheduler( val finalStage = newStage(finalRDD, None, runId) val job = new ActiveJob(runId, finalStage, func, partitions, callSite, listener, properties) clearCacheLocs() - sparkListeners.foreach(_.onJobStart(SparkListenerJobStart(job, properties))) logInfo("Got job " + job.runId + " (" + callSite + ") with " + partitions.length + " output partitions (allowLocal=" + allowLocal + ")") logInfo("Final stage: " + finalStage + " (" + finalStage.origin + ")") @@ -299,6 +298,7 @@ class DAGScheduler( // Compute very short actions like first() or take() with no parent stages locally. runLocally(job) } else { + sparkListeners.foreach(_.onJobStart(SparkListenerJobStart(job, properties))) idToActiveJob(runId) = job activeJobs += job resultStageToJob(finalStage) = job |