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 838fc82d2ee37..54f0f8e226791 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
@@ -641,18 +641,22 @@ private[ui] class TaskPagedTable(
{accumulatorsInfo(task)} |
}}
{if (hasInput(stage)) {
- metricInfo(task) { m =>
- val bytesRead = Utils.bytesToString(m.inputMetrics.bytesRead)
- val records = m.inputMetrics.recordsRead
- {bytesRead} / {records} |
- }
+ {
+ metricInfo(task) { m =>
+ val bytesRead = Utils.bytesToString(m.inputMetrics.bytesRead)
+ val records = m.inputMetrics.recordsRead
+ Unparsed(s"$bytesRead / $records")
+ }
+ } |
}}
{if (hasOutput(stage)) {
- metricInfo(task) { m =>
- val bytesWritten = Utils.bytesToString(m.outputMetrics.bytesWritten)
- val records = m.outputMetrics.recordsWritten
- {bytesWritten} / {records} |
- }
+ {
+ metricInfo(task) { m =>
+ val bytesWritten = Utils.bytesToString(m.outputMetrics.bytesWritten)
+ val records = m.outputMetrics.recordsWritten
+ Unparsed(s"$bytesWritten / $records")
+ }
+ } |
}}
{if (hasShuffleRead(stage)) {
|