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);