SparkListenerJobStart posted from local jobs

2013-11-26 22:25:20 -08:00 · 2013-11-26 22:25:20 -08:00 · 403234dd0d
parent f55d0b935d
commit 403234dd0d
1 changed files with 1 additions and 0 deletions
--- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
+++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@ -544,6 +544,7 @@ class DAGScheduler(
        logInfo("Missing parents: " + getMissingParentStages(finalStage))
        if (allowLocal && finalStage.parents.size == 0 && partitions.length == 1) {
          // Compute very short actions like first() or take() with no parent stages locally.
+          listenerBus.post(SparkListenerJobStart(job, Array(), properties))
          runLocally(job)
        } else {
          idToActiveJob(jobId) = job