diff --git spark-client/src/main/java/org/apache/hive/spark/client/MetricsCollection.java spark-client/src/main/java/org/apache/hive/spark/client/MetricsCollection.java index 2be19de3f6..f00ec42773 100644 --- spark-client/src/main/java/org/apache/hive/spark/client/MetricsCollection.java +++ spark-client/src/main/java/org/apache/hive/spark/client/MetricsCollection.java @@ -172,7 +172,7 @@ private Metrics aggregate(Predicate filter) { long shuffleWriteTime = 0L; long shuffleRecordsWritten = 0L; - // Input metrics. + // Output metrics. boolean hasOuputMetrics = false; long bytesWritten = 0L; long recordsWritten = 0L; @@ -246,7 +246,7 @@ private Metrics aggregate(Predicate filter) { } OutputMetrics outputMetrics = null; - if (hasInputMetrics) { + if (hasOuputMetrics) { outputMetrics = new OutputMetrics(bytesWritten, recordsWritten); }