Skip to content

Commit 00a65e3

Browse files
authored
[improve][broker] Change log level from warn to debug when cursor mark-deleted position ledger doesn't exist (#25200)
1 parent 6f4ac21 commit 00a65e3

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
@@ -2736,7 +2736,8 @@ public CompletableFuture<Void> maybeUpdateCursorBeforeTrimmingConsumedLedger() {
27362736
log.debug("No need to reset cursor: {}, current ledger is the last ledger.", cursor);
27372737
}
27382738
} else {
2739-
log.warn("Cursor: {} does not exist in the managed-ledger.", cursor);
2739+
// It's possible that the ledger at the mark-deleted position is empty and has been deleted already.
2740+
log.debug("Cursor: {} mark-deleted position ledger does not exist in the managed-ledger.", cursor);
27402741
}
27412742

27422743
int compareResult = lastAckedPosition.compareTo(markDeletedPosition);

0 commit comments

Comments
 (0)