You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by xy...@apache.org on 2022/08/01 10:04:48 UTC
[pulsar] 01/06: [fix][broker] ManagedCursor: mark delete no callback when create meta-ledger fail (#16841)
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 <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)
(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);