(hudi) branch master updated: fix: close InflaterInputStream in HoodieAvroDataBlock.decompress() to prevent native memory leak (#19861)

[danny0405]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new a46909b09bbb fix: close InflaterInputStream in 
HoodieAvroDataBlock.decompress() to prevent native memory leak (#19861)
a46909b09bbb is described below

commit a46909b09bbb044acda01a41dfc90ea844fe05b3
Author: Venkateswarlu Boggavarapu <mailtoboggavar...@gmail.com>
AuthorDate: Thu Sep 10 22:44:44 2026 -0400

    fix: close InflaterInputStream in HoodieAvroDataBlock.decompress() to 
prevent native memory leak (#19861)
---
 .../org/apache/hudi/common/table/log/block/HoodieAvroDataBlock.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieAvroDataBlock.java
 
b/hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieAvroDataBlock.java
index 3c187b29c7b4..145c11aca75d 100644
--- 
a/hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieAvroDataBlock.java
+++ 
b/hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieAvroDataBlock.java
@@ -477,9 +477,8 @@ public class HoodieAvroDataBlock extends HoodieDataBlock {
   }
 
   private static String decompress(byte[] bytes) {
-    InputStream in = new InflaterInputStream(new ByteArrayInputStream(bytes));
     ByteArrayOutputStream baos = new ByteArrayOutputStream();
-    try {
+    try (InputStream in = new InflaterInputStream(new 
ByteArrayInputStream(bytes))) {
       byte[] buffer = new byte[8192];
       int len;
       while ((len = in.read(buffer)) > 0) {