hive git commit: HIVE-14222 : PTF: Operator initialization does not clean state (Wei Zheng, reviewed by Gunther Hagleitner)

2016-07-14 Thread weiz
Repository: hive
Updated Branches:
  refs/heads/branch-1 3e51861a2 -> 826909d82


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/826909d8
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/826909d8
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/826909d8

Branch: refs/heads/branch-1
Commit: 826909d82ee676f11f3a8cf52c812f88e9645b03
Parents: 3e51861
Author: Wei Zheng 
Authored: Thu Jul 14 15:20:18 2016 -0700
Committer: Wei Zheng 
Committed: Thu Jul 14 15:23:29 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/826909d8/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 7d465d2..7ed1a53 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
@@ -71,6 +71,7 @@ public class PTFOperator extends Operator implements 
Serializable {
 Collection> result = super.initializeOp(jobConf);
 hiveConf = jobConf;
 isMapOperator = conf.isMapSide();
+currentKeys = null;
 
 reconstructQueryDef(hiveConf);
 



hive git commit: HIVE-14222 : PTF: Operator initialization does not clean state (Wei Zheng, reviewed by Gunther Hagleitner)

2016-07-14 Thread weiz
Repository: hive
Updated Branches:
  refs/heads/branch-2.0 72d4073a6 -> 301ed30ea


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/301ed30e
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/301ed30e
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/301ed30e

Branch: refs/heads/branch-2.0
Commit: 301ed30ea745f1e09d4ebeede6b6565dc0c33d53
Parents: 72d4073
Author: Wei Zheng 
Authored: Thu Jul 14 15:20:18 2016 -0700
Committer: Wei Zheng 
Committed: Thu Jul 14 15:22:47 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/301ed30e/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 2e9e539..8aa3285 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
@@ -81,6 +81,7 @@ public class PTFOperator extends Operator implements 
Serializable {
 super.initializeOp(jobConf);
 hiveConf = jobConf;
 isMapOperator = conf.isMapSide();
+currentKeys = null;
 
 reconstructQueryDef(hiveConf);
 



hive git commit: HIVE-14222 : PTF: Operator initialization does not clean state (Wei Zheng, reviewed by Gunther Hagleitner)

2016-07-14 Thread weiz
Repository: hive
Updated Branches:
  refs/heads/branch-2.1 48f329701 -> b48850860


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/b4885086
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/b4885086
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/b4885086

Branch: refs/heads/branch-2.1
Commit: b4885086077f8f20d5c624942adf6c42f0a06da1
Parents: 48f3297
Author: Wei Zheng 
Authored: Thu Jul 14 15:20:18 2016 -0700
Committer: Wei Zheng 
Committed: Thu Jul 14 15:22:01 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/b4885086/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 implements 
Serializable {
 super.initializeOp(jobConf);
 hiveConf = jobConf;
 isMapOperator = conf.isMapSide();
+currentKeys = null;
 
 reconstructQueryDef(hiveConf);
 



hive git commit: HIVE-14222 : PTF: Operator initialization does not clean state (Wei Zheng, reviewed by Gunther Hagleitner)

2016-07-14 Thread weiz
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 
Authored: Thu Jul 14 15:20:18 2016 -0700
Committer: Wei Zheng 
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 implements 
Serializable {
 super.initializeOp(jobConf);
 hiveConf = jobConf;
 isMapOperator = conf.isMapSide();
+currentKeys = null;
 
 reconstructQueryDef(hiveConf);