Skip to content

Commit eed610c

Browse files
committed
[fix][broker] Add debug log
1 parent 413be42 commit eed610c

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

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

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2756,7 +2756,10 @@ public void markDeleteFailed(ManagedLedgerException exception, Object ctx) {
27562756
cursor.getMarkDeletedPosition(), finalPosition, exception);
27572757
}
27582758
}, null);
2759-
} else if (compareResult < 0) {
2759+
} else if (compareResult == 0) {
2760+
log.debug("No need to reset cursor: {}, last acked position equals to current mark-delete position {}.",
2761+
markDeletedPosition);
2762+
} else {
27602763
// Should not happen
27612764
log.warn("Trying to mark delete cursor to an already mark-deleted position. Current mark-delete:"
27622765
+ " {} -- attempted position: {}", markDeletedPosition, lastAckedPosition);

0 commit comments

Comments
 (0)