From f5b71a8f2e9d9c5dd39cc715bc345b4f641d1f7e Mon Sep 17 00:00:00 2001 From: Navneet Verma Date: Thu, 2 Jan 2025 11:10:18 -0800 Subject: [PATCH] Fixed some netty configuration for s3 upload and download Signed-off-by: Navneet Verma --- .../java/org/opensearch/knn/remote/index/s3/S3Client.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/org/opensearch/knn/remote/index/s3/S3Client.java b/src/main/java/org/opensearch/knn/remote/index/s3/S3Client.java index 0d2be413a..6e1bd33e0 100644 --- a/src/main/java/org/opensearch/knn/remote/index/s3/S3Client.java +++ b/src/main/java/org/opensearch/knn/remote/index/s3/S3Client.java @@ -112,13 +112,13 @@ private S3Client() { .region(REGION) .httpClientBuilder( NettyNioAsyncHttpClient.builder() - .writeTimeout(Duration.ofSeconds(300)) + .writeTimeout(Duration.ofMinutes(5)) .maxConcurrency(100) - .readTimeout(Duration.ofSeconds(300)) + .readTimeout(Duration.ofMinutes(5)) .connectionMaxIdleTime(Duration.ofMinutes(5)) // Max idle connection time - .connectionTimeToLive(Duration.ofMinutes(10)) // Max connection lifetime + .connectionTimeToLive(Duration.ofMinutes(5)) // Max connection lifetime .maxPendingConnectionAcquires(10000) // Max queued requests - .connectionTimeout(Duration.ofSeconds(300)) // Connection establishment timeout + .connectionTimeout(Duration.ofMinutes(5)) // Connection establishment timeout .tcpKeepAlive(true) ) .credentialsProvider(StaticCredentialsProvider.create(credentials))