fix(storage): disable stalled stream protection for aws-sdk-s3 (#16170)

Signed-off-by: MrCroxx <[email protected]>
risingwavelabs · Apr 7, 2024 · cf2dfd0 · cf2dfd0
1 parent b899639
commit cf2dfd0
Showing 1 changed file with 8 additions and 1 deletion.
diff --git 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))