This is an automated email from the ASF dual-hosted git repository. nicoloboschi pushed a commit to branch branch-4.15 in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
commit 1faaaf2ad4447859677205f49fbf5321e879f774 Author: StevenLuMT <[email protected]> AuthorDate: Tue Nov 29 15:05:18 2022 +0800 InterleavedLedgerStorage: safe release ByteBuf (#3674) Co-authored-by: lushiji <[email protected]> (cherry picked from commit 25f03a046b65b1f3db61bf8d23b5611fea3f33fb) (cherry picked from commit 746799602f194b1fc6f6b7c16cc860a23578ce95) --- .../java/org/apache/bookkeeper/bookie/InterleavedLedgerStorage.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/InterleavedLedgerStorage.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/InterleavedLedgerStorage.java index a1dc14b2f6..ff79b7234f 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/InterleavedLedgerStorage.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/InterleavedLedgerStorage.java @@ -37,7 +37,7 @@ import com.google.common.util.concurrent.RateLimiter; import edu.umd.cs.findbugs.annotations.SuppressFBWarnings; import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBufAllocator; - +import io.netty.util.ReferenceCountUtil; import java.io.File; import java.io.IOException; import java.util.ArrayList; @@ -348,7 +348,7 @@ public class InterleavedLedgerStorage implements CompactableLedgerStorage, Entry lac = bb.readLong(); lac = ledgerCache.updateLastAddConfirmed(ledgerId, lac); } finally { - bb.release(); + ReferenceCountUtil.safeRelease(bb); } } }
