You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2016/11/01 22:20:15 UTC
[09/11] hive git commit: HIVE-15099 : PTFOperator.PTFInvocation
didn't properly reset the input partition (Wei Zheng,
reviewed by Ashutosh Chauhan)
HIVE-15099 : PTFOperator.PTFInvocation didn't properly reset the input partition (Wei Zheng, reviewed by Ashutosh Chauhan)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/95b17e53
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/95b17e53
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/95b17e53
Branch: refs/heads/hive-14535
Commit: 95b17e5305c99606041448a8096f4cb221bb5737
Parents: c56fa72
Author: Wei Zheng <we...@apache.org>
Authored: Mon Oct 31 17:32:33 2016 -0700
Committer: Wei Zheng <we...@apache.org>
Committed: Mon Oct 31 17:32:33 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/95b17e53/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 90e64b7..8366ea7 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
@@ -416,6 +416,7 @@ public class PTFOperator extends Operator<PTFDesc> implements Serializable {
void close() {
if ( inputPart != null ) {
inputPart.close();
+ inputPart = null;
}
tabFn.close();
if ( next != null ) {