Repository: hive Updated Branches: refs/heads/master 350445d29 -> 1c8449cce
HIVE-20168 : ReduceSinkOperator Logging Hidden (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/1c8449cc Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/1c8449cc Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/1c8449cc Branch: refs/heads/master Commit: 1c8449cce2a961c6ca6ce38bef0d770f34221d4d Parents: 350445d Author: Bharathkrishna Guruvayoor Murali <[email protected]> Authored: Mon Jul 30 10:14:26 2018 -0700 Committer: Vihang Karajgaonkar <[email protected]> Committed: Mon Jul 30 10:14:26 2018 -0700 ---------------------------------------------------------------------- .../hadoop/hive/ql/exec/ReduceSinkOperator.java | 18 +++++++----------- 1 file changed, 7 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/1c8449cc/ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java index caaf543..a2a9c84 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java @@ -500,15 +500,13 @@ public class ReduceSinkOperator extends TerminalOperator<ReduceSinkDesc> if (null != out) { numRows++; runTimeNumRows++; - if (LOG.isTraceEnabled()) { - if (numRows == cntr) { - cntr = logEveryNRows == 0 ? cntr * 10 : numRows + logEveryNRows; - if (cntr < 0 || numRows < 0) { - cntr = 0; - numRows = 1; - } - LOG.info(toString() + ": records written - " + numRows); + if (numRows == cntr) { + cntr = logEveryNRows == 0 ? cntr * 10 : numRows + logEveryNRows; + if (cntr < 0 || numRows < 0) { + cntr = 0; + numRows = 1; } + LOG.info("{}: records written - {}", this, numRows); } out.collect(keyWritable, valueWritable); } @@ -536,9 +534,7 @@ public class ReduceSinkOperator extends TerminalOperator<ReduceSinkDesc> out = null; random = null; reducerHash = null; - if (LOG.isTraceEnabled()) { - LOG.info(toString() + ": records written - " + numRows); - } + LOG.info("{}: Total records written - {}. abort - {}", this, numRows, abort); } /**
