This is an automated email from the ASF dual-hosted git repository. xyz pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d5cee50635bbe61e642b33ab8f76fd15f3d60f2e Author: 赵延 <[email protected]> AuthorDate: Mon Apr 11 12:34:36 2022 +0800 [cleanup] [broker] Remove useless code to avoid confusion in OpReadEntry#checkReadCompletion. (#15104) (cherry picked from commit 93761284b9f6875da0403f5fedb6ccbfbbcd7315) --- .../main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java index 91a6e26f567..b751034a0c4 100644 --- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java +++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java @@ -137,11 +137,6 @@ class OpReadEntry implements ReadEntriesCallback { if (entries.size() < count && cursor.hasMoreEntries() && ((PositionImpl) cursor.getReadPosition()).compareTo(maxPosition) < 0) { // We still have more entries to read from the next ledger, schedule a new async operation - if (nextReadPosition.getLedgerId() != readPosition.getLedgerId()) { - cursor.ledger.startReadOperationOnLedger(nextReadPosition, OpReadEntry.this); - } - - // Schedule next read in a different thread cursor.ledger.getExecutor().execute(safeRun(() -> { readPosition = cursor.ledger.startReadOperationOnLedger(nextReadPosition, OpReadEntry.this); cursor.ledger.asyncReadEntries(OpReadEntry.this);
