You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by cg...@apache.org on 2022/12/06 22:59:47 UTC
[drill] branch master updated: DRILL-8366: Late release of compressor memory in the Parquet writer (#2716)
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 <91...@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 {