init: Initialization preparations

apache · Jan 13, 2025 · 09d2315 · 09d2315
1 parent b22866b
commit 09d2315
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
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
@@ -217,7 +217,7 @@ 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);
+            throw new IndexOutOfBoundsException("offset is lower than minimum offset");
         }
 
         FileSegment fileSegment1 = fileSegmentList.get(index);

diff --git a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatCommitLogFile.java b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatCommitLogFile.java
@@ -68,6 +68,9 @@ public CompletableFuture<Long> getMinOffsetFromFileAsync() {
             .thenApply(buffer -> {
                 firstOffset.set(MessageFormatUtil.getQueueOffset(buffer));
                 return firstOffset.get();
+            }).exceptionally(e -> {
+                log.error("Get min offset from file failed, filePath={}", filePath, e);
+                return GET_OFFSET_ERROR;
             });
     }