fixup

apache · Feb 12, 2025 · 5b6da3c · 5b6da3c
1 parent c386906
commit 5b6da3c
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/tablefunction/S3TableValuedFunction.java b/fe/fe-core/src/main/java/org/apache/doris/tablefunction/S3TableValuedFunction.java
@@ -121,9 +121,6 @@ private String constructEndpoint(Map<String, String> properties, S3URI s3uri) th
         // get endpoint first from properties, if not present, get it from s3 uri.
         // If endpoint is missing, exception will be thrown.
         String endpoint = getOrDefaultAndRemove(properties, S3Properties.ENDPOINT, s3uri.getEndpoint().orElse(""));
-        if (Strings.isNullOrEmpty(endpoint)) {
-            throw new AnalysisException(String.format("Properties '%s' is required.", S3Properties.ENDPOINT));
-        }
         if (AzureProperties.checkAzureProviderPropertyExist(properties)) {
             String bucket = s3uri.getBucket();
             String accountName = properties.getOrDefault(S3Properties.ACCESS_KEY, "");
@@ -135,6 +132,8 @@ private String constructEndpoint(Map<String, String> properties, S3URI s3uri) th
             if (err != null) {
                 throw new AnalysisException(err);
             }
+        } else if (Strings.isNullOrEmpty(endpoint)) {
+            throw new AnalysisException(String.format("Properties '%s' is required.", S3Properties.ENDPOINT));
         }
         return endpoint;
     }