fix: Fixed array out-of-bounds exceptions caused by messages not present

apache · Jan 11, 2025 · b22866b · b22866b
1 parent 119a0be
commit b22866b
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java
@@ -215,6 +215,11 @@ public CompletableFuture<ByteBuffer> readAsync(long offset, int length) {
             }
         }
 
+        if (index < 0) {
+            log.error("FlatAppendFile#readAsync offset={} is lower than minimum offset:{}", offset, fileSegmentList.get(0).getBaseOffset());
+            return CompletableFuture.completedFuture(null);
+        }
+
         FileSegment fileSegment1 = fileSegmentList.get(index);
         FileSegment fileSegment2 = offset + length > fileSegment1.getCommitOffset() &&
             fileSegmentList.size() > index + 1 ? fileSegmentList.get(index + 1) : null;