2

Yukang-Lian · Sep 4, 2024 · d480daa · d480daa
1 parent 7108b23
commit d480daa
Showing 1 changed file with 3 additions and 11 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/LoadAction.java b/fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/LoadAction.java
@@ -349,18 +349,10 @@ private TNetworkAddress selectRedirectBackend(HttpServletRequest request, boolea
             Backend backend = Env.getCurrentSystemInfo().getBackend(debugBackendId);
             return new TNetworkAddress(backend.getHost(), backend.getHttpPort());
         }
-        if (Config.isCloudMode()) {
-            String cloudClusterName = getCloudClusterName(request);
-            if (Strings.isNullOrEmpty(cloudClusterName)) {
-                throw new LoadException("No cloud cluster name selected.");
-            }
-            return selectCloudRedirectBackend(cloudClusterName, request, groupCommit, tableId);
-        } else {
-            if (groupCommit && tableId == -1) {
-                throw new LoadException("Group commit table id wrong.");
-            }
-            return selectLocalRedirectBackend(groupCommit, request, tableId);
+        if (groupCommit && tableId == -1) {
+            throw new LoadException("Group commit table id wrong.");
         }
+        return selectLocalRedirectBackend(groupCommit, request, tableId);
     }
 
     private TNetworkAddress selectLocalRedirectBackend(boolean groupCommit, HttpServletRequest request, long tableId)