Skip to content

Commit 441e4ca

Browse files
Shawyeokcoderzc
authored andcommitted
[improve][broker] Change log level from warn to debug when cursor mark-deleted position ledger doesn't exist (#25200)
1 parent 274a359 commit 441e4ca

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2618,7 +2618,8 @@ public CompletableFuture<Void> maybeUpdateCursorBeforeTrimmingConsumedLedger() {
26182618
log.debug("No need to reset cursor: {}, current ledger is the last ledger.", cursor);
26192619
}
26202620
} else {
2621-
log.warn("Cursor: {} does not exist in the managed-ledger.", cursor);
2621+
// It's possible that the ledger at the mark-deleted position is empty and has been deleted already.
2622+
log.debug("Cursor: {} mark-deleted position ledger does not exist in the managed-ledger.", cursor);
26222623
}
26232624

26242625
int compareResult = lastAckedPosition.compareTo(markDeletedPosition);

0 commit comments

Comments
 (0)