More comments

2013-11-29 16:02:58 +08:00 · 2013-11-29 16:02:58 +08:00 · 4a1d966e26
parent 1e25086009
commit 4a1d966e26
1 changed files with 3 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
@ -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() {