HIVE-28008: ParquetFileReader is not closed in ParquetHiveSerDe.readS…

…chema (#5013). (Michal Lorek, reviewed by Ayush Saxena, Butao Zhang, Attila Turoczy)
apache · Jan 21, 2024 · 5093bb1 · 5093bb1
1 parent 529db39
commit 5093bb1
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/serde/ParquetHiveSerDe.java b/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/serde/ParquetHiveSerDe.java
@@ -412,8 +412,9 @@ public List<FieldSchema> readSchema(Configuration conf, String file) throws SerD
       FileMetaData metadata;
       try {
         HadoopInputFile inputFile = HadoopInputFile.fromPath(new Path(file), conf);
-        ParquetFileReader reader = ParquetFileReader.open(inputFile);
-        metadata = reader.getFileMetaData();
+        try(ParquetFileReader reader = ParquetFileReader.open(inputFile)) {
+          metadata = reader.getFileMetaData();
+        }
       } catch (Exception e) {
         throw new SerDeException(ErrorMsg.PARQUET_FOOTER_ERROR.getErrorCodedMsg(), e);
       }