We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f3723c4 commit 0a2d9a1Copy full SHA for 0a2d9a1
core/src/main/scala/org/apache/spark/util/JsonProtocol.scala
@@ -331,6 +331,7 @@ private[spark] object JsonProtocol {
331
("Total Records Read" -> shuffleReadMetrics.recordsRead)
332
}
333
334
+ // TODO: Drop the redundant "Shuffle" since it's inconsistent with related classes.
335
def shuffleWriteMetricsToJson(shuffleWriteMetrics: ShuffleWriteMetrics): JValue = {
336
("Shuffle Bytes Written" -> shuffleWriteMetrics.bytesWritten) ~
337
("Shuffle Write Time" -> shuffleWriteMetrics.writeTime) ~
0 commit comments