fix(issues2193): retry 2 times to cover most of BlockNotContinuousExc…

…eption (#2194) Signed-off-by: Robin Han <hanxvdovehx@gmail.com>
AutoMQ · Nov 29, 2024 · d6641d7 · d6641d7
1 parent fba35b6
commit d6641d7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/cache/blockcache/StreamReader.java b/s3stream/src/main/java/com/automq/stream/s3/cache/blockcache/StreamReader.java
@@ -101,7 +101,7 @@ public CompletableFuture<ReadDataBlock> read(long startOffset, long endOffset, i
         }
         reading = true;
         try {
-            return read(startOffset, endOffset, maxBytes, 1).whenComplete((rst, ex) -> reading = false);
+            return read(startOffset, endOffset, maxBytes, 2).whenComplete((rst, ex) -> reading = false);
         } catch (Throwable e) {
             reading = false;
             return FutureUtil.failedFuture(e);