diff --git a/be/src/common/config.cpp b/be/src/common/config.cpp index 60c793197a271b..8a464abbe22917 100644 --- a/be/src/common/config.cpp +++ b/be/src/common/config.cpp @@ -1472,6 +1472,7 @@ DEFINE_mInt32(max_s3_client_retry, "10"); DEFINE_mInt32(s3_read_base_wait_time_ms, "100"); DEFINE_mInt32(s3_read_max_wait_time_ms, "800"); DEFINE_mBool(enable_s3_object_check_after_upload, "true"); +DEFINE_mInt32(aws_client_request_timeout_ms, "30000"); DEFINE_mBool(enable_s3_rate_limiter, "false"); DEFINE_mInt64(s3_get_bucket_tokens, "1000000000000000000"); diff --git a/be/src/common/config.h b/be/src/common/config.h index 1d3e173a918b9b..5616ca7b526c1d 100644 --- a/be/src/common/config.h +++ b/be/src/common/config.h @@ -1580,6 +1580,7 @@ DECLARE_mInt32(max_s3_client_retry); DECLARE_mInt32(s3_read_base_wait_time_ms); DECLARE_mInt32(s3_read_max_wait_time_ms); DECLARE_mBool(enable_s3_object_check_after_upload); +DECLARE_mInt32(aws_client_request_timeout_ms); // write as inverted index tmp directory DECLARE_String(tmp_file_dir); diff --git a/be/src/util/s3_util.h b/be/src/util/s3_util.h index 39e5d8e807c3c6..c85e831fa07f18 100644 --- a/be/src/util/s3_util.h +++ b/be/src/util/s3_util.h @@ -150,6 +150,7 @@ class S3ClientFactory { // So here we use a static instance, and deep copy every time // to avoid unnecessary operations. static Aws::Client::ClientConfiguration instance; + instance.requestTimeoutMs = config::aws_client_request_timeout_ms; return instance; }