From 839934140f1a518acae8c60fe82c2253f911ea33 Mon Sep 17 00:00:00 2001
From: Andrew Or <andrewor14@gmail.com>
Date: Mon, 13 Jan 2014 20:51:38 -0800
Subject: [PATCH] Wording changes per Patrick
---
.../scala/org/apache/spark/ui/jobs/ExecutorTable.scala | 4 ++--
.../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(
--
GitLab