commit 7150dcfea818c1f4ab9af281b95188ec2c1fdd23 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 16d7c519fa8cfd05f1f6ddcacd60782701ae9e29..684d2f8af40cb5728cfd3cc07bbdce6c7592558a 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 { + LOG.info(toString() + ": Total records read - " + numRows); + super.closeOp(abort); + } + @Override public void process(Object row, int tag) throws HiveException { throw new HiveException("Hive 2 Internal error: should not be called!");