Add more aggressive healthchecking for CRT client

slackhq · Sep 15, 2023 · 0cc2f9d · 0cc2f9d
1 parent afa1ba9
commit 0cc2f9d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/kaldb/src/main/java/com/slack/kaldb/blobfs/s3/S3CrtBlobFs.java b/kaldb/src/main/java/com/slack/kaldb/blobfs/s3/S3CrtBlobFs.java
@@ -92,9 +92,10 @@ public static S3AsyncClient initS3Client(KaldbConfigs.S3Config config) {
       // continue to attempt to read data from a socket that is no longer returning data
       S3CrtHttpConfiguration.Builder httpConfigurationBuilder =
           S3CrtHttpConfiguration.builder()
+              .connectionTimeout(Duration.ofSeconds(5))
               .connectionHealthConfiguration(
                   S3CrtConnectionHealthConfiguration.builder()
-                      .minimumThroughputTimeout(Duration.ofSeconds(15))
+                      .minimumThroughputTimeout(Duration.ofSeconds(3))
                       .minimumThroughputInBps(32000L)
                       .build());