From 095160954d83849cedf51ccfefc6742816b0fc00 Mon Sep 17 00:00:00 2001 From: Fokko Driesprong Date: Mon, 4 Feb 2019 21:39:54 +0100 Subject: [PATCH] [PARQUET-1470] Inputstream leakage in ParquetFileWriter.appendFile Add a try-with-resource --- .../java/org/apache/parquet/hadoop/ParquetFileWriter.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetFileWriter.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetFileWriter.java index 20efe47573..5d4f6b76fd 100644 --- a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetFileWriter.java +++ b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetFileWriter.java @@ -664,7 +664,9 @@ public void appendFile(Configuration conf, Path file) throws IOException { } public void appendFile(InputFile file) throws IOException { - ParquetFileReader.open(file).appendTo(this); + try (ParquetFileReader reader = ParquetFileReader.open(file)) { + reader.appendTo(this); + } } public int merge(List inputFiles, CodecFactory.BytesCompressor compressor, String createdBy, long maxBlockSize) throws IOException {