From d480daa0bbe268075e1df45c8b9f140d44fa8881 Mon Sep 17 00:00:00 2001 From: Yukang-Lian Date: Wed, 4 Sep 2024 15:42:37 +0800 Subject: [PATCH] 2 --- .../org/apache/doris/httpv2/rest/LoadAction.java | 14 +++----------- 1 file changed, 3 insertions(+), 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 index 481b1ccc85a14c1..612f209fdb093f4 100644 --- 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)