[drill] branch master updated: DRILL-8366: Late release of compressor memory in the Parquet writer (#2716)

[cgivre]

This is an automated email from the ASF dual-hosted git repository.

cgivre pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git


The following commit(s) were added to refs/heads/master by this push:
     new 53e4227650 DRILL-8366: Late release of compressor memory in the 
Parquet writer (#2716)
53e4227650 is described below

commit 53e4227650755607db961b758b7966b1d6d4582f
Author: James Turton <9107319+jntur...@users.noreply.github.com>
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 {