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 <[email protected]>
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);