This is an automated email from the ASF dual-hosted git repository. mattisonchao pushed a commit to branch branch-2.9 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 29b23acd510dda129cf6eca84ad673fd67e37c73 Author: fengyubiao <[email protected]> AuthorDate: Fri Jul 29 11:21:11 2022 +0800 [fix][broker] ManagedCursor: mark delete no callback when create meta-ledger fail (#16841) (cherry picked from commit 5faac761372c5b0848924d6607a8da77f209679c) --- .../java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java index ddd4408e29e..5fb4cb356ff 100644 --- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java +++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java @@ -1799,8 +1799,10 @@ public class ManagedCursorImpl implements ManagedCursor { return; case NoLedger: - // We need to create a new ledger to write into + pendingMarkDeleteOps.add(mdEntry); + // We need to create a new ledger to write into. startCreatingNewMetadataLedger(); + break; // fall through case SwitchingLedger: pendingMarkDeleteOps.add(mdEntry);
