You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ma...@apache.org on 2022/08/04 10:05:01 UTC
[pulsar] 03/03: [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.
mattisonchao pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 29b23acd510dda129cf6eca84ad673fd67e37c73
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 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);