diff --git a/aws/src/main/java/org/apache/iceberg/aws/AwsClientFactories.java b/aws/src/main/java/org/apache/iceberg/aws/AwsClientFactories.java index e6eb8d28d01a..e27fbe28b69d 100644 --- a/aws/src/main/java/org/apache/iceberg/aws/AwsClientFactories.java +++ b/aws/src/main/java/org/apache/iceberg/aws/AwsClientFactories.java @@ -138,6 +138,7 @@ public S3AsyncClient s3Async() { .applyMutation( b -> s3FileIOProperties.applyCredentialConfigurations(awsClientProperties, b)) .applyMutation(s3FileIOProperties::applyEndpointConfigurations) + .applyMutation(s3FileIOProperties::applyServiceConfigurations) .build(); } diff --git a/aws/src/main/java/org/apache/iceberg/aws/s3/S3FileIOProperties.java b/aws/src/main/java/org/apache/iceberg/aws/s3/S3FileIOProperties.java index 922010d61d27..9ab63b55843a 100644 --- a/aws/src/main/java/org/apache/iceberg/aws/s3/S3FileIOProperties.java +++ b/aws/src/main/java/org/apache/iceberg/aws/s3/S3FileIOProperties.java @@ -1006,7 +1006,7 @@ private AwsCredentialsProvider getCredentialsProvider(AwsClientProperties awsCli * S3Client.builder().applyMutation(s3FileIOProperties::applyS3ServiceConfigurations) * */ - public void applyServiceConfigurations(T builder) { + public void applyServiceConfigurations(T builder) { builder .dualstackEnabled(isDualStackEnabled) .crossRegionAccessEnabled(isCrossRegionAccessEnabled)