diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java index 70d6468..5698639 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java @@ -451,6 +451,11 @@ private void processVectorGroup(BytesWritable keyWritable, } reducer.process(batch, tag); + // Do the non-column batch reset logic. + batch.selectedInUse = false; + batch.size = 0; + batch.endOfFile = false; + // Reset just the value columns and value buffer. for (int i = firstValueColumnOffset; i < batch.numCols; i++) { // Note that reset also resets the data buffer for bytes column vectors.