From 13bf1054ce19cf642b81237e8ccdff117c297e20 Mon Sep 17 00:00:00 2001 From: wenbingshen Date: Fri, 13 Feb 2026 15:35:58 +0800 Subject: [PATCH] fix writeLac memory leak --- .../java/org/apache/bookkeeper/client/PendingWriteLacOp.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/PendingWriteLacOp.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/PendingWriteLacOp.java index f9a5397daf0..ed3748850e3 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/PendingWriteLacOp.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/PendingWriteLacOp.java @@ -17,6 +17,7 @@ */ package org.apache.bookkeeper.client; +import io.netty.util.ReferenceCountUtil; import java.util.BitSet; import java.util.List; import org.apache.bookkeeper.client.AsyncCallback.AddLacCallback; @@ -112,6 +113,8 @@ public void writeLacComplete(int rc, long ledgerId, BookieId addr, Object ctx) { if (receivedResponseSet.isEmpty()){ completed = true; + ReferenceCountUtil.release(toSend); + toSend = null; cb.addLacComplete(lastSeenError, lh, ctx); } }