Moving some code into the Accumulators class

Author: pwendell

core/src/main/scala/org/apache/spark/Accumulators.scala

@@ -289,4 +289,7 @@ private object Accumulators {
       }
     }
   }
+
+  def stringifyPartialValue(partialValue: Any) = "%s".format(value)
+  def stringifyValue(value: Any) = "%s".format(value)
 }

core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala

@@ -907,7 +907,6 @@ class DAGScheduler(
       listenerBus.post(SparkListenerStageCompleted(stage.info))
       runningStages -= stage
     }
-
     event.reason match {
       case Success =>
         if (event.accumUpdates != null) {
@@ -918,8 +917,8 @@ class DAGScheduler(
             // To avoid UI cruft, ignore cases where value wasn't updated
             if (acc.name.isDefined && partialValue != acc.zero) {
               val name = acc.name.get
-              val stringPartialValue = "%s".format(partialValue)
-              val stringValue = "%s".format(acc.value)
+              val stringPartialValue = Accumulators.stringifyPartialValue(partialValue)
+              val stringValue = Accumulators.stringifyValue(acc.value)
               stage.info.accumulables(id) = AccumulableInfo(id, name, stringValue)
               event.taskInfo.accumulables +=
                 AccumulableInfo(id, name, Some(stringPartialValue), stringValue)

core/src/main/scala/org/apache/spark/scheduler/TaskInfo.scala

@@ -46,7 +46,7 @@ class TaskInfo(
   /**
    * Intermediate updates to accumulables during this task. Note that it is valid for the same
    * accumulable to be updated multiple times in a single task or for two accumulables with the
-   * same name but different ID's to exist in a task.
+   * same name but different IDs to exist in a task.
    */
   val accumulables = ListBuffer[AccumulableInfo]()