commit 2f88878b612769a3ab156d46a4681e71e29dc014 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..ee715773996c9e68cff21fb1275e2cece2edd4d3 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(toString() + ": records written - " + 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(toString() + ": Total records written - " + numRows); } /**