commit ac6794257299a4b2fa3161dd4f0a4d5a230a310b Author: Bharath Krishna Date: Mon Jul 23 13:40:35 2018 -0700 HIVE-20168 : Fix ReduceSinkOperator Logging Hidden diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java index caaf543e27d4f841d3c5f16127dc1f4f69d57164..a2a9c8421e7d03da85be9debd7ae361eed9a7771 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java @@ -500,15 +500,13 @@ protected void collect(BytesWritable keyWritable, Writable valueWritable) throws 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 @@ protected void closeOp(boolean abort) throws HiveException { out = null; random = null; reducerHash = null; - if (LOG.isTraceEnabled()) { - LOG.info(toString() + ": records written - " + numRows); - } + LOG.info("{}: Total records written - {}. abort - {}", this, numRows, abort); } /**