From d1ede5d4e5530b34cc2960d4d3281b87613567f1 Mon Sep 17 00:00:00 2001 From: zhaohaidao2008 Date: Mon, 7 Nov 2022 19:01:10 +0800 Subject: [PATCH] Apply recycle logic during add entry creation but ledger close to LedgerHandleAdv --- .../main/java/org/apache/bookkeeper/client/LedgerHandleAdv.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandleAdv.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandleAdv.java index 8440faf37b8..92bddc9cc4f 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandleAdv.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandleAdv.java @@ -248,6 +248,7 @@ public void run() { LOG.warn("Attempt to add to closed ledger: {}", ledgerId); op.cb.addCompleteWithLatency(BKException.Code.LedgerClosedException, LedgerHandleAdv.this, op.getEntryId(), 0, op.ctx); + op.recyclePendAddOpObject(); } @Override public String toString() { @@ -258,6 +259,7 @@ public String toString() { op.cb.addCompleteWithLatency(BookKeeper.getReturnRc(clientCtx.getBookieClient(), BKException.Code.InterruptedException), LedgerHandleAdv.this, op.getEntryId(), 0, op.ctx); + op.recyclePendAddOpObject(); } return; }