You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by we...@apache.org on 2016/07/14 22:19:16 UTC
hive git commit: HIVE-14222 : PTF: Operator initialization does not
clean state (Wei Zheng, reviewed by Gunther Hagleitner)
Repository: hive
Updated Branches:
refs/heads/master 0cce1a61a -> 29a259bea
HIVE-14222 : PTF: Operator initialization does not clean state (Wei Zheng, reviewed by Gunther Hagleitner)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/29a259be
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/29a259be
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/29a259be
Branch: refs/heads/master
Commit: 29a259bea18757b3ecc868997d24ac7048f6eb4d
Parents: 0cce1a6
Author: Wei Zheng <we...@apache.org>
Authored: Thu Jul 14 15:20:18 2016 -0700
Committer: Wei Zheng <we...@apache.org>
Committed: Thu Jul 14 15:20:18 2016 -0700
----------------------------------------------------------------------
ql/src/java/org/apache/hadoop/hive/ql/exec/PTFOperator.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/29a259be/ql/src/java/org/apache/hadoop/hive/ql/exec/PTFOperator.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/PTFOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/PTFOperator.java
index 37ae8fe..90e64b7 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/PTFOperator.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/PTFOperator.java
@@ -79,6 +79,7 @@ public class PTFOperator extends Operator<PTFDesc> implements Serializable {
super.initializeOp(jobConf);
hiveConf = jobConf;
isMapOperator = conf.isMapSide();
+ currentKeys = null;
reconstructQueryDef(hiveConf);