Actor instead of eventQueue for LocalJobCompleted
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/6f8359b5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/6f8359b5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/6f8359b5 Branch: refs/heads/master Commit: 6f8359b5ad6c069c6105631a6c74e225b866cfce Parents: 51458ab Author: Mark Hamstra <[email protected]> Authored: Tue Nov 19 10:16:48 2013 -0800 Committer: Mark Hamstra <[email protected]> Committed: Tue Dec 3 09:57:31 2013 -0800 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/6f8359b5/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 10417b9..ad436f8 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala @@ -694,7 +694,7 @@ class DAGScheduler( case e: Exception => job.listener.jobFailed(e) } finally { - eventQueue.put(LocalJobCompleted(job.finalStage)) + eventProcessActor ! LocalJobCompleted(job.finalStage) } }
