Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
mmm committed Oct 31, 2014
1 parent c28c449 commit 390893b
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala
Original file line number Diff line number Diff line change
Expand Up @@ -248,9 +248,7 @@ private[ui] class StagePage(parent: JobProgressTab) extends WebUIPage("stage") {
val serializationTime = metrics.map(_.resultSerializationTime).getOrElse(0L)

val maybeAccumulators = info.accumulables
//val accumulatorsSortable = maybeAccumulators.map(_.name)
val accumulatorsReadable = maybeAccumulators
.map{acc => s"${acc.name}: ${acc.update.get}"}
val accumulatorsReadable = maybeAccumulators.map{acc => s"${acc.name}: ${acc.update.get}"}

val maybeInput = metrics.flatMap(_.inputMetrics)
val inputSortable = maybeInput.map(_.bytesRead.toString).getOrElse("")
Expand Down

0 comments on commit 390893b

Please sign in to comment.