diff --git a/fluss-filesystems/fluss-fs-s3/src/main/java/org/apache/fluss/fs/s3/token/S3DelegationTokenProvider.java b/fluss-filesystems/fluss-fs-s3/src/main/java/org/apache/fluss/fs/s3/token/S3DelegationTokenProvider.java index b582e4d35e..5c3100c9e4 100644 --- a/fluss-filesystems/fluss-fs-s3/src/main/java/org/apache/fluss/fs/s3/token/S3DelegationTokenProvider.java +++ b/fluss-filesystems/fluss-fs-s3/src/main/java/org/apache/fluss/fs/s3/token/S3DelegationTokenProvider.java @@ -52,6 +52,7 @@ public class S3DelegationTokenProvider { private static final String REGION_KEY = "fs.s3a.region"; private static final String ENDPOINT_KEY = "fs.s3a.endpoint"; + private static final String PATH_STYLE_ACCESS_KEY = "fs.s3a.path.style.access"; private static final String ROLE_ARN_KEY = "fs.s3a.assumed.role.arn"; private static final String STS_ENDPOINT_KEY = "fs.s3a.assumed.role.sts.endpoint"; @@ -83,7 +84,7 @@ public S3DelegationTokenProvider(String scheme, Configuration conf) { } this.additionInfos = new HashMap<>(); - for (String key : Arrays.asList(REGION_KEY, ENDPOINT_KEY)) { + for (String key : Arrays.asList(REGION_KEY, ENDPOINT_KEY, PATH_STYLE_ACCESS_KEY)) { if (conf.get(key) != null) { additionInfos.put(key, conf.get(key)); }