You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by vi...@apache.org on 2018/08/02 16:14:39 UTC
hive git commit: HIVE-20169 : Print Final Rows Processed in
MapOperator (Bharathkrishna Guruvayoor Murali reviewed by Vihang
Karajgaonkar)
Repository: hive
Updated Branches:
refs/heads/master 6917821fc -> 19187bed0
HIVE-20169 : Print Final Rows Processed in MapOperator (Bharathkrishna Guruvayoor Murali reviewed by Vihang Karajgaonkar)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/19187bed
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/19187bed
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/19187bed
Branch: refs/heads/master
Commit: 19187bed0d8fa8250c7a76b84e3a39a420f32bf8
Parents: 6917821
Author: Bharathkrishna Guruvayoor Murali <bh...@cloudera.com>
Authored: Thu Aug 2 09:07:06 2018 -0700
Committer: Vihang Karajgaonkar <vi...@apache.org>
Committed: Thu Aug 2 09:07:06 2018 -0700
----------------------------------------------------------------------
ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/19187bed/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java
index 16d7c51..c7350ca 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java
@@ -677,6 +677,12 @@ public class MapOperator extends AbstractMapOperator {
}
@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!");
}