diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/PTFOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/PTFOperator.java index 90e64b7..8366ea7 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/PTFOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/PTFOperator.java @@ -416,6 +416,7 @@ private void createInputPartition() throws HiveException { void close() { if ( inputPart != null ) { inputPart.close(); + inputPart = null; } tabFn.close(); if ( next != null ) {