diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/LoadStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/LoadStmt.java
index 6a45e5eabf38a6..6abe6fdc860425 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/LoadStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/LoadStmt.java
@@ -606,13 +606,8 @@ public RedirectStatus getRedirectStatus() {
     private void checkEndpoint(String endpoint) throws UserException {
         HttpURLConnection connection = null;
         try {
-            String urlStr = endpoint;
-            // Add default protocol if not specified
-            if (!endpoint.startsWith("http://") && !endpoint.startsWith("https://")) {
-                urlStr = "http://" + endpoint;
-            }
-            SecurityChecker.getInstance().startSSRFChecking(urlStr);
-            URL url = new URL(urlStr);
+            SecurityChecker.getInstance().startSSRFChecking(endpoint);
+            URL url = new URL(endpoint);
             connection = (HttpURLConnection) url.openConnection();
             connection.setConnectTimeout(10000);
             connection.connect();
@@ -646,6 +641,11 @@ public void checkS3Param() throws UserException {
                 && brokerDescProperties.containsKey(S3Properties.Env.REGION)) {
             String endpoint = brokerDescProperties.get(S3Properties.Env.ENDPOINT);
             checkWhiteList(endpoint);
+            // Add default protocol if not specified
+            if (!endpoint.startsWith("http://") && !endpoint.startsWith("https://")) {
+                endpoint = "http://" + endpoint;
+            }
+            brokerDescProperties.put(S3Properties.Env.ENDPOINT, endpoint);
             if (AzureProperties.checkAzureProviderPropertyExist(brokerDescProperties)) {
                 return;
             }
diff --git a/fe/fe-core/src/main/java/org/apache/doris/cloud/storage/DefaultRemote.java b/fe/fe-core/src/main/java/org/apache/doris/cloud/storage/DefaultRemote.java
index 661caf8874661e..41e43c3e1181e8 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/cloud/storage/DefaultRemote.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/cloud/storage/DefaultRemote.java
@@ -129,7 +129,11 @@ private void initClient() {
                 credentials = AwsBasicCredentials.create(obj.getAk(), obj.getSk());
             }
             StaticCredentialsProvider scp = StaticCredentialsProvider.create(credentials);
-            URI endpointUri = URI.create("http://" + obj.getEndpoint());
+            String endpoint = obj.getEndpoint();
+            if (!endpoint.startsWith("http://") && !endpoint.startsWith("https://")) {
+                endpoint = "http://" + endpoint;
+            }
+            URI endpointUri = URI.create(endpoint);
             s3Client = S3Client.builder().endpointOverride(endpointUri).credentialsProvider(scp)
                     .region(Region.of(obj.getRegion())).build();
         }