commit 53e4227650755607db961b758b7966b1d6d4582f
author James Turton <9107319+jnturton@users.noreply.github.com> Wed Dec 07 00:59:40 2022 +0200
committer GitHub <noreply@github.com> Tue Dec 06 17:59:40 2022 -0500
tree 79fea26f60837bc67cb5c0d058df69343bda6822
parent 1bd0e9c61aa7c8951d01ab4832e930951e0a4db7

DRILL-8366: Late release of compressor memory in the Parquet writer (#2716)

exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java

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 bcea784..5858b08 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 @@
     } finally {
       store.close();
       pageStore.close();
+      codecFactory.release();
 
       store = null;
       pageStore = null;
@@ -741,8 +742,6 @@
   @Override
   public void cleanup() throws IOException {
     flush(true);
-
-    codecFactory.release();
   }
 
   private void createParquetFileWriter() throws IOException {