You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zh...@apache.org on 2026/02/26 03:56:02 UTC
(pulsar) branch branch-4.0 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.
zhaocong pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new 441e4ca05df [improve][broker] Change log level from warn to debug when cursor mark-deleted position ledger doesn't exist (#25200)
441e4ca05df is described below
commit 441e4ca05dfa857fc981723b6c566d1bf0b8f1fa
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 6183e77de99..95ba53312b4 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
@@ -2618,7 +2618,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);