Skip to content

Commit a72d351

Browse files
committed
[fix][broker] Modify logic
1 parent d4d79e9 commit a72d351

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

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

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2715,11 +2715,8 @@ public CompletableFuture<Void> maybeUpdateCursorBeforeTrimmingConsumedLedger() {
27152715
cursorMarkDeleteFutures.add(future);
27162716

27172717
// Snapshot positions into a local variables to avoid race condition.
2718-
Position persistentMarkDeletedPosition = cursor.getPersistentMarkDeletedPosition();
27192718
Position markDeletedPosition = cursor.getMarkDeletedPosition();
2720-
Position lastAckedPosition =
2721-
persistentMarkDeletedPosition != null ? persistentMarkDeletedPosition : markDeletedPosition;
2722-
// Position lastAckedPosition = markDeletedPosition;
2719+
Position lastAckedPosition = markDeletedPosition;
27232720
LedgerInfo curPointedLedger = ledgers.get(lastAckedPosition.getLedgerId());
27242721
LedgerInfo nextPointedLedger = Optional.ofNullable(ledgers.higherEntry(lastAckedPosition.getLedgerId()))
27252722
.map(Map.Entry::getValue).orElse(null);

0 commit comments

Comments
 (0)