You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2026/02/06 11:33:07 UTC
(pulsar) branch master updated: [improve][broker] Change log level from warn to debug when cursor mark-deleted position ledger doesn't exist (#25200)
This is an automated email from the ASF dual-hosted git repository.
lhotari 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 00a65e33172 [improve][broker] Change log level from warn to debug when cursor mark-deleted position ledger doesn't exist (#25200)
00a65e33172 is described below
commit 00a65e331724973ce963ea38d1c0f7edbcb0d3c4
Author: Yike Xiao <km...@live.com>
AuthorDate: Fri Feb 6 19:33:01 2026 +0800
[improve][broker] Change log level from warn to debug when cursor mark-deleted position ledger doesn't exist (#25200)
---
.../java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java
index b7affb01929..ce0bf59edc7 100644
--- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java
+++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java
@@ -2736,7 +2736,8 @@ public class ManagedLedgerImpl implements ManagedLedger, CreateCallback {
log.debug("No need to reset cursor: {}, current ledger is the last ledger.", cursor);
}
} else {
- log.warn("Cursor: {} does not exist in the managed-ledger.", cursor);
+ // It's possible that the ledger at the mark-deleted position is empty and has been deleted already.
+ log.debug("Cursor: {} mark-deleted position ledger does not exist in the managed-ledger.", cursor);
}
int compareResult = lastAckedPosition.compareTo(markDeletedPosition);