From c423be7d8e1349fc00431328b76b52f4eee8a975 Mon Sep 17 00:00:00 2001
From: Patrick Wendell <pwendell@gmail.com>
Date: Thu, 24 Jan 2013 18:25:57 -0800
Subject: [PATCH] Renaming stage finished function

---
 core/src/main/scala/spark/scheduler/DAGScheduler.scala | 6 +++---
 1 file 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)