srowen closed pull request #23483: [MINOR][WEBUI]Modify the name of the column
named "shuffle spill" in the StagePage
URL: https://github.com/apache/spark/pull/23483
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git a/core/src/main/resources/org/apache/spark/ui/static/stagepage.js
b/core/src/main/resources/org/apache/spark/ui/static/stagepage.js
index 08de2b0fee034..5b792ffc584d1 100644
--- a/core/src/main/resources/org/apache/spark/ui/static/stagepage.js
+++ b/core/src/main/resources/org/apache/spark/ui/static/stagepage.js
@@ -100,10 +100,10 @@ function getColumnNameForTaskMetricSummary(columnKey) {
return "Scheduler Delay";
case "diskBytesSpilled":
- return "Shuffle spill (disk)";
+ return "Spill (disk)";
case "memoryBytesSpilled":
- return "Shuffle spill (memory)";
+ return "Spill (memory)";
case "shuffleReadMetrics":
return "Shuffle Read Size / Records";
@@ -842,7 +842,7 @@ $(document).ready(function () {
return "";
}
},
- name: "Shuffle Spill (Memory)"
+ name: "Spill (Memory)"
},
{
data : function (row, type) {
@@ -852,7 +852,7 @@ $(document).ready(function () {
return "";
}
},
- name: "Shuffle Spill (Disk)"
+ name: "Spill (Disk)"
},
{
data : function (row, type) {
diff --git
a/core/src/main/resources/org/apache/spark/ui/static/stagespage-template.html
b/core/src/main/resources/org/apache/spark/ui/static/stagespage-template.html
index 6f950c61b2d63..6b0435bb20281 100644
---
a/core/src/main/resources/org/apache/spark/ui/static/stagespage-template.html
+++
b/core/src/main/resources/org/apache/spark/ui/static/stagespage-template.html
@@ -59,8 +59,8 @@ <h4 class="title-table">Aggregated Metrics by Executor</h4>
<th><span id="executor-summary-output">Output Size /
Records</span></th>
<th><span id="executor-summary-shuffle-read">Shuffle Read Size
/ Records</span></th>
<th><span id="executor-summary-shuffle-write">Shuffle Write
Size / Records</span></th>
- <th>Shuffle Spill (Memory) </th>
- <th>Shuffle Spill (Disk) </th>
+ <th>Spill (Memory) </th>
+ <th>Spill (Disk) </th>
</thead>
<tbody>
</tbody>
@@ -111,8 +111,8 @@ <h4 id="tasksTitle" class="title-table"></h4>
<th>Write Time</th>
<th>Shuffle Write Size / Records</th>
<th>Shuffle Read Size / Records</th>
- <th>Shuffle Spill (Memory)</th>
- <th>Shuffle Spill (Disk)</th>
+ <th>Spill (Memory)</th>
+ <th>Spill (Disk)</th>
<th>Errors</th>
</tr>
</thead>
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 a213b764abea7..3bca1d5743018 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
@@ -188,11 +188,11 @@ private[ui] class StagePage(parent: StagesTab, store:
AppStatusStore) extends We
}}
{if (hasBytesSpilled(stageData)) {
<li>
- <strong>Shuffle Spill (Memory): </strong>
+ <strong>Spill (Memory): </strong>
{Utils.bytesToString(stageData.memoryBytesSpilled)}
</li>
<li>
- <strong>Shuffle Spill (Disk): </strong>
+ <strong>Spill (Disk): </strong>
{Utils.bytesToString(stageData.diskBytesSpilled)}
</li>
}}
@@ -797,8 +797,8 @@ private[spark] object ApiHelper {
val HEADER_SHUFFLE_REMOTE_READS = "Shuffle Remote Reads"
val HEADER_SHUFFLE_WRITE_TIME = "Write Time"
val HEADER_SHUFFLE_WRITE_SIZE = "Shuffle Write Size / Records"
- val HEADER_MEM_SPILL = "Shuffle Spill (Memory)"
- val HEADER_DISK_SPILL = "Shuffle Spill (Disk)"
+ val HEADER_MEM_SPILL = "Spill (Memory)"
+ val HEADER_DISK_SPILL = "Spill (Disk)"
val HEADER_ERROR = "Errors"
private[ui] val COLUMN_TO_INDEX = Map(
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
