diff --git a/core/src/main/scala/org/apache/spark/Accumulators.scala b/core/src/main/scala/org/apache/spark/Accumulators.scala index 4185d185699d1..845eaabf43703 100644 --- a/core/src/main/scala/org/apache/spark/Accumulators.scala +++ b/core/src/main/scala/org/apache/spark/Accumulators.scala @@ -99,16 +99,6 @@ class Accumulable[R, T] ( } } - /** - * Function to customize printing values of this accumulator. - */ - def prettyValue(_value: R) = s"$value" - - /** - * Function to customize printing partially accumulated (local) values of this accumulator. - */ - def prettyPartialValue(_value: R) = prettyValue(_value) - /** * Get the current value of this accumulator from within a task. * 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 846a313e8ae54..03a8c98c0a95a 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala @@ -822,8 +822,8 @@ class DAGScheduler( val name = acc.name // To avoid UI cruft, ignore cases where value wasn't updated if (partialValue != acc.zero) { - val stringPartialValue = acc.prettyPartialValue(partialValue) - val stringValue = acc.prettyValue(acc.value) + val stringPartialValue = "%s".format(partialValue) + val stringValue = "%s".format(acc.value) stageToInfos(stage).accumulables(id) = AccumulableInfo(id, acc.name, stringValue) event.taskInfo.accumulables += AccumulableInfo(id, name, Some(stringPartialValue), stringValue)