This is an automated email from the ASF dual-hosted git repository. dzamo pushed a commit to branch 1.20 in repository https://gitbox.apache.org/repos/asf/drill.git
commit 6d36a8a82370e57cc484d0a5c90b36129ff3d728 Author: James Turton <[email protected]> AuthorDate: Wed Dec 7 00:59:40 2022 +0200 DRILL-8366: Late release of compressor memory in the Parquet writer (#2716) --- .../java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java index bcea784051..5858b08f4b 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java @@ -477,6 +477,7 @@ public class ParquetRecordWriter extends ParquetOutputRecordWriter { } finally { store.close(); pageStore.close(); + codecFactory.release(); store = null; pageStore = null; @@ -741,8 +742,6 @@ public class ParquetRecordWriter extends ParquetOutputRecordWriter { @Override public void cleanup() throws IOException { flush(true); - - codecFactory.release(); } private void createParquetFileWriter() throws IOException {
