diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java index 044ce41bfb9fc6..01e2d7f6f19983 100644 --- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java +++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java @@ -3473,6 +3473,7 @@ public void deactivateCursor(ManagedCursor cursor) { if (!cursor.isDurable()) { nonDurableActiveCursors.removeCursor(cursor.getName()); } + waitingCursors.remove(cursor); } }