diff --git a/hadoop-tools/hadoop-aliyun/src/main/java/org/apache/hadoop/fs/aliyun/oss/AliyunOSSFileSystemStore.java b/hadoop-tools/hadoop-aliyun/src/main/java/org/apache/hadoop/fs/aliyun/oss/AliyunOSSFileSystemStore.java index 67fdc6779f92f..658cf40583c68 100644 --- a/hadoop-tools/hadoop-aliyun/src/main/java/org/apache/hadoop/fs/aliyun/oss/AliyunOSSFileSystemStore.java +++ b/hadoop-tools/hadoop-aliyun/src/main/java/org/apache/hadoop/fs/aliyun/oss/AliyunOSSFileSystemStore.java @@ -181,7 +181,7 @@ public void initialize(URI uri, Configuration conf, String user, ossClient.setBucketAcl(bucketName, cannedACL); statistics.incrementWriteOps(1); } - + if (StringUtils.isNotEmpty(region)) { ossClient.setRegion(region); LOG.debug("ossClient setRegion {}", region);