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 2017/05/30 21:17:16 UTC
[07/12] hive git commit: HIVE-16765: ParquetFileReader should be
closed to avoid resource leak (Colin Ma, reviewed by Ferdinand Xu)
HIVE-16765: ParquetFileReader should be closed to avoid resource leak (Colin Ma, reviewed by Ferdinand Xu)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/3330403a
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/3330403a
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/3330403a
Branch: refs/heads/hive-14535
Commit: 3330403a7dea206c85828dfd5319a7ae0d9bcef5
Parents: ca80968
Author: Ferdinand Xu <ch...@intel.com>
Authored: Sat May 27 07:35:40 2017 +0800
Committer: Ferdinand Xu <ch...@intel.com>
Committed: Sat May 27 07:35:40 2017 +0800
----------------------------------------------------------------------
.../hive/ql/io/parquet/vector/VectorizedParquetRecordReader.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/3330403a/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/vector/VectorizedParquetRecordReader.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/vector/VectorizedParquetRecordReader.java b/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/vector/VectorizedParquetRecordReader.java
index 96d3847..65b4398 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/vector/VectorizedParquetRecordReader.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/vector/VectorizedParquetRecordReader.java
@@ -259,6 +259,9 @@ public class VectorizedParquetRecordReader extends ParquetRecordReaderBase
@Override
public void close() throws IOException {
+ if (reader != null) {
+ reader.close();
+ }
}
@Override