Github user dongjoon-hyun commented on a diff in the pull request: https://github.com/apache/spark/pull/22555#discussion_r220656095 --- Diff: core/src/main/scala/org/apache/spark/executor/Executor.scala --- @@ -464,7 +464,7 @@ private[spark] class Executor( executorSource.METRIC_OUTPUT_BYTES_WRITTEN .inc(task.metrics.outputMetrics.bytesWritten) executorSource.METRIC_OUTPUT_RECORDS_WRITTEN - .inc(task.metrics.inputMetrics.recordsRead) + .inc(task.metrics.outputMetrics.recordsWritten) --- End diff -- Could you remove `[MINOR]`? Actually, SPARK-25536 issue is marked as 'MAJOR' bug.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org