Repository: hive Updated Branches: refs/heads/master 804535275 -> a4dd84b38
HIVE-20496: Vectorization: Vectorized PTF IllegalStateException (Matt McCline, reviewed by Teddy Choi) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/a4dd84b3 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/a4dd84b3 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/a4dd84b3 Branch: refs/heads/master Commit: a4dd84b38083864edc2e09e52e208827b82e82cd Parents: 8045352 Author: Matt McCline <mmccl...@hortonworks.com> Authored: Mon Sep 3 05:42:29 2018 -0500 Committer: Matt McCline <mmccl...@hortonworks.com> Committed: Mon Sep 3 05:42:29 2018 -0500 ---------------------------------------------------------------------- .../org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/a4dd84b3/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java index 70d6468..5698639 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java @@ -451,6 +451,11 @@ public class ReduceRecordSource implements RecordSource { } 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.
