Skip to content

Commit b4a7fa7

Browse files
witgoJoshRosen
authored andcommitted
[SPARK-3905][Web UI]The keys for sorting the columns of Executor page ,Stage page Storage page are incorrect
Author: GuoQiang Li <[email protected]> Closes apache#2763 from witgo/SPARK-3905 and squashes the following commits: 17d7990 [GuoQiang Li] The keys for sorting the columns of Executor page ,Stage page Storage page are incorrect
1 parent fc616d5 commit b4a7fa7

File tree

3 files changed

+12
-12
lines changed

3 files changed

+12
-12
lines changed

core/src/main/scala/org/apache/spark/ui/jobs/ExecutorTable.scala

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -71,19 +71,19 @@ private[ui] class ExecutorTable(stageId: Int, stageAttemptId: Int, parent: JobPr
7171
<tr>
7272
<td>{k}</td>
7373
<td>{executorIdToAddress.getOrElse(k, "CANNOT FIND ADDRESS")}</td>
74-
<td sorttable_customekey={v.taskTime.toString}>{UIUtils.formatDuration(v.taskTime)}</td>
74+
<td sorttable_customkey={v.taskTime.toString}>{UIUtils.formatDuration(v.taskTime)}</td>
7575
<td>{v.failedTasks + v.succeededTasks}</td>
7676
<td>{v.failedTasks}</td>
7777
<td>{v.succeededTasks}</td>
78-
<td sorttable_customekey={v.inputBytes.toString}>
78+
<td sorttable_customkey={v.inputBytes.toString}>
7979
{Utils.bytesToString(v.inputBytes)}</td>
80-
<td sorttable_customekey={v.shuffleRead.toString}>
80+
<td sorttable_customkey={v.shuffleRead.toString}>
8181
{Utils.bytesToString(v.shuffleRead)}</td>
82-
<td sorttable_customekey={v.shuffleWrite.toString}>
82+
<td sorttable_customkey={v.shuffleWrite.toString}>
8383
{Utils.bytesToString(v.shuffleWrite)}</td>
84-
<td sorttable_customekey={v.memoryBytesSpilled.toString}>
84+
<td sorttable_customkey={v.memoryBytesSpilled.toString}>
8585
{Utils.bytesToString(v.memoryBytesSpilled)}</td>
86-
<td sorttable_customekey={v.diskBytesSpilled.toString}>
86+
<td sorttable_customkey={v.diskBytesSpilled.toString}>
8787
{Utils.bytesToString(v.diskBytesSpilled)}</td>
8888
</tr>
8989
}

core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -176,9 +176,9 @@ private[ui] class StageTableBase(
176176
{makeProgressBar(stageData.numActiveTasks, stageData.completedIndices.size,
177177
stageData.numFailedTasks, s.numTasks)}
178178
</td>
179-
<td sorttable_customekey={inputRead.toString}>{inputReadWithUnit}</td>
180-
<td sorttable_customekey={shuffleRead.toString}>{shuffleReadWithUnit}</td>
181-
<td sorttable_customekey={shuffleWrite.toString}>{shuffleWriteWithUnit}</td>
179+
<td sorttable_customkey={inputRead.toString}>{inputReadWithUnit}</td>
180+
<td sorttable_customkey={shuffleRead.toString}>{shuffleReadWithUnit}</td>
181+
<td sorttable_customkey={shuffleWrite.toString}>{shuffleWriteWithUnit}</td>
182182
}
183183

184184
/** Render an HTML row that represents a stage */

core/src/main/scala/org/apache/spark/ui/storage/StoragePage.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -58,9 +58,9 @@ private[ui] class StoragePage(parent: StorageTab) extends WebUIPage("") {
5858
</td>
5959
<td>{rdd.numCachedPartitions}</td>
6060
<td>{"%.0f%%".format(rdd.numCachedPartitions * 100.0 / rdd.numPartitions)}</td>
61-
<td sorttable_customekey={rdd.memSize.toString}>{Utils.bytesToString(rdd.memSize)}</td>
62-
<td sorttable_customekey={rdd.tachyonSize.toString}>{Utils.bytesToString(rdd.tachyonSize)}</td>
63-
<td sorttable_customekey={rdd.diskSize.toString} >{Utils.bytesToString(rdd.diskSize)}</td>
61+
<td sorttable_customkey={rdd.memSize.toString}>{Utils.bytesToString(rdd.memSize)}</td>
62+
<td sorttable_customkey={rdd.tachyonSize.toString}>{Utils.bytesToString(rdd.tachyonSize)}</td>
63+
<td sorttable_customkey={rdd.diskSize.toString} >{Utils.bytesToString(rdd.diskSize)}</td>
6464
</tr>
6565
// scalastyle:on
6666
}

0 commit comments

Comments
 (0)