commit 7cde52daa90c9c51a27b825285b86912640490e3 Author: Bharath Krishna Date: Fri Jul 20 14:55:47 2018 -0700 HIVE-20169 : Print Final number of rows Processed in MapOperator diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java index 16d7c519fa..c7350ca5b4 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java @@ -676,6 +676,12 @@ private String toErrorMessage(Writable value, Object row, ObjectInspector inspec return vcValues; } + @Override + public void closeOp(boolean abort) throws HiveException { + super.closeOp(abort); + LOG.info("{}: Total records read - {}. abort - {}", this, numRows, abort); + } + @Override public void process(Object row, int tag) throws HiveException { throw new HiveException("Hive 2 Internal error: should not be called!");