You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/08/08 09:04:21 UTC
[pulsar] 17/33: [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.
penghui pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 86ceb3f692fb64e4eca7b2af9dd7c3f47796946b
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 863f1cc9fd5..feeaffd1dd8 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
@@ -1860,8 +1860,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);