From c525e2590f44c813e5def4916ed47413b5fe7a7e Mon Sep 17 00:00:00 2001 From: Croxx Date: Sun, 7 Apr 2024 14:38:32 +0800 Subject: [PATCH] fix(storage): disable stalled stream protection for aws-sdk-s3 (#16170) Signed-off-by: MrCroxx --- src/object_store/src/object/s3.rs | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/src/object_store/src/object/s3.rs b/src/object_store/src/object/s3.rs index 196638f1e3689..43a118dd829af 100644 --- a/src/object_store/src/object/s3.rs +++ b/src/object_store/src/object/s3.rs @@ -602,6 +602,9 @@ impl S3ObjectStore { )) .build(), ) + .stalled_stream_protection( + aws_sdk_s3::config::StalledStreamProtectionConfig::disabled(), + ) .build(), ); client @@ -621,6 +624,9 @@ impl S3ObjectStore { )) .build(), ) + .stalled_stream_protection( + aws_sdk_s3::config::StalledStreamProtectionConfig::disabled(), + ) .build(), ); client @@ -681,7 +687,8 @@ impl S3ObjectStore { .build(), ) .http_client(Self::new_http_client(&s3_object_store_config)) - .behavior_version_latest(); + .behavior_version_latest() + .stalled_stream_protection(aws_sdk_s3::config::StalledStreamProtectionConfig::disabled()); let config = builder .region(Region::new("custom")) .endpoint_url(format!("{}{}", endpoint_prefix, address))