hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mmccl...@apache.org
Subject hive git commit: HIVE-20496: Vectorization: Vectorized PTF IllegalStateException (Matt McCline, reviewed by Teddy Choi)
Date Mon, 03 Sep 2018 10:42:46 GMT
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 <mmccline@hortonworks.com>
Authored: Mon Sep 3 05:42:29 2018 -0500
Committer: Matt McCline <mmccline@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.


Mime
View raw message