diff options
author | Andrew Or <andrewor14@gmail.com> | 2014-01-13 20:51:38 -0800 |
---|---|---|
committer | Andrew Or <andrewor14@gmail.com> | 2014-01-13 20:51:38 -0800 |
commit | 839934140f1a518acae8c60fe82c2253f911ea33 (patch) | |
tree | e8b637d0a278c96b05d7ca57aa258617a9706c48 | |
parent | a1f0992faefbe042a9cb7a11842a817c958e4797 (diff) | |
download | spark-839934140f1a518acae8c60fe82c2253f911ea33.tar.gz spark-839934140f1a518acae8c60fe82c2253f911ea33.tar.bz2 spark-839934140f1a518acae8c60fe82c2253f911ea33.zip |
Wording changes per Patrick
-rw-r--r-- | core/src/main/scala/org/apache/spark/ui/jobs/ExecutorTable.scala | 4 | ||||
-rw-r--r-- | core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala | 10 |
2 files changed, 7 insertions, 7 deletions
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 7b7325322a..ab03eb5ce1 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 8f89fad2fd..113f76bf33 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( |