diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-01-24 18:25:57 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-01-28 10:45:57 -0800 |
| commit | c423be7d8e1349fc00431328b76b52f4eee8a975 (patch) | |
| tree | d13236efbaf136f8de24d1ba96b18cfe477acc29 /core | |
| parent | 07f568e1bfc67eead88e2c5dbfb9cac23e1ac8bc (diff) | |
| download | spark-c423be7d8e1349fc00431328b76b52f4eee8a975.tar.gz spark-c423be7d8e1349fc00431328b76b52f4eee8a975.tar.bz2 spark-c423be7d8e1349fc00431328b76b52f4eee8a975.zip | |
Renaming stage finished function
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/scheduler/DAGScheduler.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/core/src/main/scala/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/spark/scheduler/DAGScheduler.scala index 8aad667182..bce7418e87 100644 --- a/core/src/main/scala/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/spark/scheduler/DAGScheduler.scala @@ -412,7 +412,7 @@ class DAGScheduler(taskSched: TaskScheduler) extends TaskSchedulerListener with val task = event.task val stage = idToStage(task.stageId) - def stageFinished(stage: Stage) = { + def markStageAsFinished(stage: Stage) = { val serviceTime = stageSubmissionTimes.remove(stage) match { case Some(t) => (System.currentTimeMillis() - t).toString case _ => "Unkown" @@ -438,7 +438,7 @@ class DAGScheduler(taskSched: TaskScheduler) extends TaskSchedulerListener with if (job.numFinished == job.numPartitions) { activeJobs -= job resultStageToJob -= stage - stageFinished(stage) + markStageAsFinished(stage) } job.listener.taskSucceeded(rt.outputId, event.result) } @@ -457,7 +457,7 @@ class DAGScheduler(taskSched: TaskScheduler) extends TaskSchedulerListener with stage.addOutputLoc(smt.partition, status) } if (running.contains(stage) && pendingTasks(stage).isEmpty) { - stageFinished(stage) + markStageAsFinished(stage) logInfo("looking for newly runnable stages") logInfo("running: " + running) logInfo("waiting: " + waiting) |