From d4f22710fcab4d38875c4f58b6b8fcc4d75ba0af Mon Sep 17 00:00:00 2001 From: Robin Han Date: Fri, 23 Feb 2024 22:01:18 +0800 Subject: [PATCH] fix(s3stream): trust get objects Signed-off-by: Robin Han --- .../src/main/java/com/automq/stream/s3/cache/StreamReader.java | 1 - 1 file changed, 1 deletion(-) diff --git a/s3stream/src/main/java/com/automq/stream/s3/cache/StreamReader.java b/s3stream/src/main/java/com/automq/stream/s3/cache/StreamReader.java index 0bb2baf75..3cea50a19 100644 --- a/s3stream/src/main/java/com/automq/stream/s3/cache/StreamReader.java +++ b/s3stream/src/main/java/com/automq/stream/s3/cache/StreamReader.java @@ -405,7 +405,6 @@ CompletableFuture getDataBlockIndices(TraceContext traceContext, long stre if (context.objectIndex >= context.objects.size()) { getObjectsCf = objectManager .getObjects(streamId, context.nextStartOffset, endOffset, READ_OBJECT_INDEX_STEP) - .orTimeout(1, TimeUnit.MINUTES) .thenApply(objects -> { context.objects = objects; context.objectIndex = 0;