diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/ExecutorTable.scala b/core/src/main/scala/org/apache/spark/ui/jobs/ExecutorTable.scala index 7b7325322a242449bf3908fdc24123b16105447d..ab03eb5ce1ab42fc86df6956b47c74f4c54ac64d 100644 --- a/core/src/main/scala/org/apache/spark/ui/jobs/ExecutorTable.scala +++ b/core/src/main/scala/org/apache/spark/ui/jobs/ExecutorTable.scala @@ -48,8 +48,8 @@ private[spark] class ExecutorTable(val parent: JobProgressUI, val stageId: Int) <th>Succeeded Tasks</th> <th>Shuffle Read</th> <th>Shuffle Write</th> - <th>Bytes Spilled (Memory)</th> - <th>Bytes Spilled (Disk)</th> + <th>Shuffle Spill (Memory)</th> + <th>Shuffle Spill (Disk)</th> </thead> <tbody> {createExecutorTable()} diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala b/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala index 8f89fad2fd75b5c328b79e0af821da40013efce7..113f76bf3364a4c3365714ed4246688558ee1e1b 100644 --- a/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala +++ b/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala @@ -86,11 +86,11 @@ private[spark] class StagePage(parent: JobProgressUI) { } {if (hasBytesSpilled) <li> - <strong>Bytes spilled (memory): </strong> + <strong>Shuffle spill (memory): </strong> {Utils.bytesToString(memoryBytesSpilled)} </li> <li> - <strong>Bytes spilled (disk): </strong> + <strong>Shuffle spill (disk): </strong> {Utils.bytesToString(diskBytesSpilled)} </li> } @@ -102,7 +102,7 @@ private[spark] class StagePage(parent: JobProgressUI) { Seq("Duration", "GC Time", "Result Ser Time") ++ {if (hasShuffleRead) Seq("Shuffle Read") else Nil} ++ {if (hasShuffleWrite) Seq("Write Time", "Shuffle Write") else Nil} ++ - {if (hasBytesSpilled) Seq("Bytes Spilled (Memory)", "Bytes Spilled (Disk)") else Nil} ++ + {if (hasBytesSpilled) Seq("Shuffle Spill (Memory)", "Shuffle Spill (Disk)") else Nil} ++ Seq("Errors") val taskTable = listingTable(taskHeaders, taskRow(hasShuffleRead, hasShuffleWrite, hasBytesSpilled), tasks) @@ -171,14 +171,14 @@ private[spark] class StagePage(parent: JobProgressUI) { case(info, metrics, exception) => metrics.get.memoryBytesSpilled.toDouble } - val memoryBytesSpilledQuantiles = "Bytes spilled (memory)" +: + val memoryBytesSpilledQuantiles = "Shuffle spill (memory)" +: getQuantileCols(memoryBytesSpilledSizes) val diskBytesSpilledSizes = validTasks.map { case(info, metrics, exception) => metrics.get.diskBytesSpilled.toDouble } - val diskBytesSpilledQuantiles = "Bytes spilled (disk)" +: + val diskBytesSpilledQuantiles = "Shuffle spill (disk)" +: getQuantileCols(diskBytesSpilledSizes) val listings: Seq[Seq[String]] = Seq(