This is an automated email from the ASF dual-hosted git repository. xyz pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 9061e902afd36d2a0b52ff734a736789d1e62ce2 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 c653e0090e8..a6036cca066 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 @@ -1794,8 +1794,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);
