commit a500c948911455c0b642565342f40d46b166c4be 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..bc04555f30314e87d22a4b45a87300f18fb7056b 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("{}: Total records read - {}", this, 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!");