mridulm commented on code in PR #36165:
URL: https://github.com/apache/spark/pull/36165#discussion_r1012357823
##########
core/src/main/scala/org/apache/spark/executor/ShuffleReadMetrics.scala:
##########
@@ -146,6 +268,16 @@ private[spark] class TempShuffleReadMetrics extends
ShuffleReadMetricsReporter {
override def incLocalBytesRead(v: Long): Unit = _localBytesRead += v
override def incFetchWaitTime(v: Long): Unit = _fetchWaitTime += v
override def incRecordsRead(v: Long): Unit = _recordsRead += v
+ override def incCorruptMergedBlockChunks(v: Long): Unit =
_corruptMergedBlockChunks += v
+ override def incFallbackCount(v: Long): Unit = _fallbackCount += v
+ override def incRemoteMergedBlocksFetched(v: Long): Unit =
_remoteMergedBlocksFetched += v
+ override def incLocalMergedBlocksFetched(v: Long): Unit =
_localMergedBlocksFetched += v
+ override def incRemoteMergedChunksFetched(v: Long): Unit =
_remoteMergedChunksFetched += v
+ override def incLocalMergedChunksFetched(v: Long): Unit =
_localMergedChunksFetched += v
+ override def incRemoteMergedBlocksBytesRead(v: Long): Unit =
_remoteMergedBlocksBytesRead += v
+ override def incLocalMergedBlocksBytesRead(v: Long): Unit =
_localMergedBlocksBytesRead += v
+ override def incRemoteReqsDuration(v: Long): Unit = _remoteReqsDuration += v
+ override def incRemoteMergedReqsDuration(v: Long): Unit =
_remoteMergedReqsDuration += v
Review Comment:
I called out the same
[above](https://github.com/apache/spark/pull/36165#discussion_r978229580)
I am fine with pulling those two metrics out and introducing them in a
different PR
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
