diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyConverter.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyConverter.java
index fb130d8a01..4b8ad06c7d 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyConverter.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyConverter.java
@@ -17,6 +17,7 @@
 
 package org.apache.doris.datasource.property;
 
+import org.apache.doris.common.util.Util;
 import org.apache.doris.datasource.credentials.CloudCredential;
 import org.apache.doris.datasource.credentials.CloudCredentialWithEndpoint;
 import org.apache.doris.datasource.iceberg.IcebergExternalCatalog;
@@ -126,7 +127,8 @@ public class PropertyConverter {
                                                                 CloudCredentialWithEndpoint credential) {
         // Old properties to new properties
         properties.put(S3Properties.ENDPOINT, credential.getEndpoint());
-        properties.put(S3Properties.REGION, credential.getRegion());
+        properties.put(S3Properties.REGION,
+                    checkRegion(credential.getEndpoint(), credential.getRegion(), S3Properties.Env.REGION));
         properties.put(S3Properties.ACCESS_KEY, credential.getAccessKey());
         properties.put(S3Properties.SECRET_KEY, credential.getSecretKey());
         if (properties.containsKey(S3Properties.Env.TOKEN)) {
@@ -149,7 +151,8 @@ public class PropertyConverter {
         Map<String, String> s3Properties = Maps.newHashMap();
         String endpoint = properties.get(S3Properties.ENDPOINT);
         s3Properties.put(Constants.ENDPOINT, endpoint);
-        s3Properties.put(Constants.AWS_REGION, S3Properties.getRegionOfEndpoint(endpoint));
+        s3Properties.put(Constants.AWS_REGION,
+                    checkRegion(endpoint, properties.get(S3Properties.REGION), S3Properties.REGION));
         if (properties.containsKey(S3Properties.MAX_CONNECTIONS)) {
             s3Properties.put(Constants.MAXIMUM_CONNECTIONS, properties.get(S3Properties.MAX_CONNECTIONS));
         }
@@ -164,6 +167,17 @@ public class PropertyConverter {
         return s3Properties;
     }
 
+    private static String checkRegion(String endpoint, String region, String regionKey) {
+        if (Strings.isNullOrEmpty(region)) {
+            region = S3Properties.getRegionOfEndpoint(endpoint);
+        }
+        if (Strings.isNullOrEmpty(region)) {
+            String errorMsg = String.format("Required property '%s' when region is not in endpoint.", regionKey);
+            Util.logAndThrowRuntimeException(LOG, errorMsg, new IllegalArgumentException(errorMsg));
+        }
+        return region;
+    }
+
     private static void setS3FsAccess(Map<String, String> s3Properties, Map<String, String> properties,
                                       CloudCredential credential) {
         s3Properties.put(Constants.MAX_ERROR_RETRIES, "2");
diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/property/constants/S3Properties.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/property/constants/S3Properties.java
index 3927e23644..f91b752f8f 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/datasource/property/constants/S3Properties.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/property/constants/S3Properties.java
@@ -113,7 +113,7 @@ public class S3Properties extends BaseProperties {
             throw new IllegalArgumentException("Missing 'AWS_ENDPOINT' property. ");
         }
         String endpoint = props.get(Env.ENDPOINT);
-        String region = props.getOrDefault(S3Properties.REGION, S3Properties.getRegionOfEndpoint(endpoint));
+        String region = props.getOrDefault(Env.REGION, S3Properties.getRegionOfEndpoint(endpoint));
         return new CloudCredentialWithEndpoint(endpoint, region, credential);
     }