fix(s3stream): temporarily disable throttle for slow read (#1009)

Signed-off-by: Shichao Nie <[email protected]>
AutoMQ · Mar 24, 2024 · 155a6c0 · 155a6c0
1 parent d41aea3
commit 155a6c0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/ObjectReader.java b/s3stream/src/main/java/com/automq/stream/s3/ObjectReader.java
@@ -65,7 +65,7 @@ public CompletableFuture<FindIndexResult> find(long streamId, long startOffset,
     }
 
     public CompletableFuture<DataBlockGroup> read(DataBlockIndex block) {
-        CompletableFuture<ByteBuf> rangeReadCf = s3Operator.rangeRead(objectKey, block.startPosition(), block.endPosition(), ThrottleStrategy.THROTTLE_1);
+        CompletableFuture<ByteBuf> rangeReadCf = s3Operator.rangeRead(objectKey, block.startPosition(), block.endPosition(), ThrottleStrategy.BYPASS);
         return rangeReadCf.thenApply(DataBlockGroup::new);
     }
 

diff --git a/s3stream/src/main/java/com/automq/stream/s3/S3Stream.java b/s3stream/src/main/java/com/automq/stream/s3/S3Stream.java
@@ -197,7 +197,7 @@ public CompletableFuture<FetchResult> fetch(FetchContext context,
                     if (context.readOptions().fastRead()) {
                         networkOutboundLimiter.forceConsume(totalSize);
                     } else {
-                        return networkOutboundLimiter.consume(ThrottleStrategy.THROTTLE_1, totalSize).thenApply(nil -> rs);
+                        return networkOutboundLimiter.consume(ThrottleStrategy.BYPASS, totalSize).thenApply(nil -> rs);
                     }
                 }
                 return CompletableFuture.completedFuture(rs);