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 6dd886fe4ea2b..e7edd3827882c 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 CompletableFuture maybeUpdateCursorBeforeTrimmingConsumedLedger() { 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);