[pulsar] branch master updated: [fix][broker] ManagedCursor: mark delete no callback when create meta-ledger fail (#16841)

[te...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 5faac761372 [fix][broker] ManagedCursor: mark delete no callback when create meta-ledger fail (#16841)
5faac761372 is described below

commit 5faac761372c5b0848924d6607a8da77f209679c
Author: fengyubiao <yu...@streamnative.io>
AuthorDate: Fri Jul 29 11:21:11 2022 +0800

    [fix][broker] ManagedCursor: mark delete no callback when create meta-ledger fail (#16841)
---
 .../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 e7ec241291d..83ee356e5c3 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
@@ -1868,8 +1868,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);