[cleanup] [broker] Remove useless code to avoid confusion in OpReadEn…

…try#checkReadCompletion. (#15104) (cherry picked from commit 9376128)
apache · Aug 7, 2022 · c397e91 · c397e91
1 parent acf472c
commit c397e91
Showing 1 changed file with 0 additions and 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
@@ -131,11 +131,6 @@ void updateReadPosition(Position newReadPosition) {
     void checkReadCompletion() {
         if (entries.size() < count && cursor.hasMoreEntries()) {
             // 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);