remove prefetch

apache · Sep 29, 2024 · 0fb7f4f · 0fb7f4f
1 parent 382e09f
commit 0fb7f4f
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueue.java b/store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueue.java
@@ -245,9 +245,6 @@ public ReferredIterator<CqUnit> iterateFrom(final long startIndex) {
             long maxCqOffset = getMaxOffsetInQueue();
             if (startIndex < maxCqOffset) {
                 int num = pullNum(startIndex, maxCqOffset);
-                if (num <= 16) {
-                    return iterateFrom0(startIndex, num);
-                }
                 return new LargeRocksDBConsumeQueueIterator(startIndex, num);
             }
         } catch (RocksDBException e) {