diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java index 990a4f1..f09a384 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java @@ -437,6 +437,7 @@ private boolean processKeyValues(Iterable values, byte tag) throws HiveE private boolean processVectors(Iterable values, byte tag) throws HiveException { VectorizedRowBatch batch = batches[tag]; batch.reset(); + buffer.reset(); /* deserialize key into columns */ VectorizedBatchUtil.addRowToBatchFrom(keyObject, keyStructInspector,