feat(s3stream): fast fail s3 request (#2281)

superhx · web-flow · commit b4c5341e4359 · 2025-02-06T10:02:13.000+08:00
Signed-off-by: Robin Han &lt;hanxvdovehx@gmail.com&gt;
diff --git a/s3stream/src/main/java/com/automq/stream/s3/operator/AwsObjectStorage.java b/s3stream/src/main/java/com/automq/stream/s3/operator/AwsObjectStorage.java
@@ -427,8 +427,8 @@ protected S3AsyncClient newS3Client(String endpoint, String region, boolean forc
 
     protected ClientOverrideConfiguration clientOverrideConfiguration() {
         return ClientOverrideConfiguration.builder()
-            .apiCallTimeout(Duration.ofMinutes(2))
-            .apiCallAttemptTimeout(Duration.ofSeconds(60))
+            .apiCallTimeout(Duration.ofSeconds(30))
+            .apiCallAttemptTimeout(Duration.ofSeconds(10))
             .build();
     }
 

Original file line number	Diff line number	Diff line change
`@@ -427,8 +427,8 @@ protected S3AsyncClient newS3Client(String endpoint, String region, boolean forc`
`427`	`427`
`428`	`428`	`protected ClientOverrideConfiguration clientOverrideConfiguration() {`
`429`	`429`	`return ClientOverrideConfiguration.builder()`
`430`		`- .apiCallTimeout(Duration.ofMinutes(2))`
`431`		`- .apiCallAttemptTimeout(Duration.ofSeconds(60))`
	`430`	`+ .apiCallTimeout(Duration.ofSeconds(30))`
	`431`	`+ .apiCallAttemptTimeout(Duration.ofSeconds(10))`
`432`	`432`	`.build();`
`433`	`433`	`}`
`434`	`434`