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

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 6c798d64f0 [ISSUE #9593] Optimize Deflater resource release (#9594)
6c798d64f0 is described below

commit 6c798d64f0732693d430622a019275a722e927c3
Author: yx9o <[email protected]>
AuthorDate: Fri Nov 14 13:44:15 2025 +0800

    [ISSUE #9593] Optimize Deflater resource release (#9594)
---
 .../main/java/org/apache/rocketmq/common/compression/ZlibCompressor.java | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/common/src/main/java/org/apache/rocketmq/common/compression/ZlibCompressor.java
 
b/common/src/main/java/org/apache/rocketmq/common/compression/ZlibCompressor.java
index e64db9b62a..f6dcebdee9 100644
--- 
a/common/src/main/java/org/apache/rocketmq/common/compression/ZlibCompressor.java
+++ 
b/common/src/main/java/org/apache/rocketmq/common/compression/ZlibCompressor.java
@@ -41,7 +41,6 @@ public class ZlibCompressor implements Compressor {
             deflaterOutputStream.close();
             result = byteArrayOutputStream.toByteArray();
         } catch (IOException e) {
-            defeater.end();
             throw e;
         } finally {
             try {

Reply via email to