diff options
| author | Lian, Cheng <rhythm.mail@gmail.com> | 2013-11-29 16:02:58 +0800 |
|---|---|---|
| committer | Lian, Cheng <rhythm.mail@gmail.com> | 2013-11-29 16:02:58 +0800 |
| commit | 4a1d966e26e56fc5d42a828f414b4eca433c3a22 (patch) | |
| tree | e786f51789f1e6f3885f60ce791b40b99ac2f082 /core | |
| parent | 1e25086009ff6421790609e406d00e1b978d6dbe (diff) | |
| download | spark-4a1d966e26e56fc5d42a828f414b4eca433c3a22.tar.gz spark-4a1d966e26e56fc5d42a828f414b4eca433c3a22.tar.bz2 spark-4a1d966e26e56fc5d42a828f414b4eca433c3a22.zip | |
More comments
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 3 |
1 files changed, 3 insertions, 0 deletions
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 08cf76325b..bc37a70e98 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala @@ -167,6 +167,9 @@ class DAGScheduler( */ def start() { eventProcessActor = env.actorSystem.actorOf(Props(new Actor { + /** + * A handle to the periodical task, used to cancel the task when the actor is stopped. + */ var resubmissionTask: Cancellable = _ override def preStart() { |