From 05c6782ffdfca8da921ded8a42e53d0fcbdf0b2d Mon Sep 17 00:00:00 2001 From: dao-jun Date: Thu, 30 May 2024 13:28:28 +0800 Subject: [PATCH] Revert PR 6404 --- .../bookkeeper/mledger/impl/ManagedCursorImpl.java | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java index 18d9cd7cb0568..c8d7452e1d418 100644 --- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java +++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java @@ -1559,15 +1559,7 @@ public String toString() { }; positions.stream().filter(position -> !alreadyAcknowledgedPositions.contains(position)) - .forEach(p ->{ - if (((PositionImpl) p).compareTo(this.readPosition) == 0) { - this.setReadPosition(this.readPosition.getNext()); - log.warn("[{}][{}] replayPosition{} equals readPosition{}," + " need set next readPosition", - ledger.getName(), name, p, this.readPosition); - } - ledger.asyncReadEntry((PositionImpl) p, cb, ctx); - }); - + .forEach(p -> ledger.asyncReadEntry((PositionImpl) p, cb, ctx)); return alreadyAcknowledgedPositions; }