Index: ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java (revision 1633992) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java (working copy) @@ -499,14 +499,16 @@ throw new HiveException("Hive Runtime Error while processing row " + message, e); } } - rowForwarded(childrenDone); + rowsForwarded(childrenDone, 1); } - protected final void rowForwarded(int childrenDone) { - numRows++; - if (isLogInfoEnabled && numRows == cntr) { - cntr *= 10; - LOG.info(toString() + ": records read - " + numRows); + protected final void rowsForwarded(int childrenDone, int rows) { + numRows += rows; + if (isLogInfoEnabled) { + while (numRows >= cntr) { + cntr *= 10; + LOG.info(toString() + ": records read - " + numRows); + } } if (childrenDone == currentCtxs.length) { setDone(true); Index: ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorMapOperator.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorMapOperator.java (revision 1633992) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorMapOperator.java (working copy) @@ -46,7 +46,8 @@ childrenDone++; } } - rowForwarded(childrenDone); + + rowsForwarded(childrenDone, ((VectorizedRowBatch)value).size); } catch (Exception e) { throw new HiveException("Hive Runtime Error while processing row ", e); }