Repository: hive Updated Branches: refs/heads/branch-3 6bb450208 -> 90cca4a5e
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/90cca4a5 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/90cca4a5 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/90cca4a5 Branch: refs/heads/branch-3 Commit: 90cca4a5e45aeadc821d9f51818607bfddf281af Parents: 6bb4502 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:37:27 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/90cca4a5/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); } /**
