You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ma...@apache.org on 2013/12/06 20:50:12 UTC
[11/12] git commit: SparkListenerJobStart posted from local jobs
SparkListenerJobStart posted from local jobs
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/403234dd
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/403234dd
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/403234dd
Branch: refs/heads/master
Commit: 403234dd0d63a7e89f3304d7bb31e3675d405a13
Parents: f55d0b9
Author: Mark Hamstra <ma...@gmail.com>
Authored: Tue Nov 26 22:25:20 2013 -0800
Committer: Mark Hamstra <ma...@gmail.com>
Committed: Tue Dec 3 09:57:32 2013 -0800
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/403234dd/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
index b849867..f9cd021 100644
--- 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