(doris) branch master updated: [fix](case) Fix some non cloud regression case `failed to get cloud c… (#41249)

[hellostephen]

This is an automated email from the ASF dual-hosted git repository.

hellostephen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new 02d2eda6215 [fix](case) Fix some non cloud regression case `failed to 
get cloud c… (#41249)
02d2eda6215 is described below

commit 02d2eda6215094383f739981ff51f65a51b6772e
Author: deardeng <565620...@qq.com>
AuthorDate: Wed Sep 25 15:03:04 2024 +0800

    [fix](case) Fix some non cloud regression case `failed to get cloud c… 
(#41249)
    
    …ompute group`
    
    ## Proposed changes
    
    Issue Number: close #xxx
    
    <!--Describe your changes.-->
---
 .../java/org/apache/doris/qe/MasterOpExecutor.java  | 21 ++++++++++++---------
 1 file changed, 12 insertions(+), 9 deletions(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/MasterOpExecutor.java 
b/fe/fe-core/src/main/java/org/apache/doris/qe/MasterOpExecutor.java
index 9e4a5744e1e..1df8dda4e8f 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/MasterOpExecutor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/MasterOpExecutor.java
@@ -22,6 +22,7 @@ import org.apache.doris.analysis.RedirectStatus;
 import org.apache.doris.catalog.Env;
 import org.apache.doris.common.AnalysisException;
 import org.apache.doris.common.ClientPool;
+import org.apache.doris.common.Config;
 import org.apache.doris.common.DdlException;
 import org.apache.doris.common.ErrorCode;
 import org.apache.doris.thrift.FrontendService;
@@ -211,15 +212,17 @@ public class MasterOpExecutor {
         params.setStmtId(ctx.getStmtId());
         params.setCurrentUserIdent(ctx.getCurrentUserIdentity().toThrift());
 
-        String cluster = "";
-        try {
-            cluster = ctx.getCloudCluster(false);
-        } catch (Exception e) {
-            LOG.warn("failed to get cloud compute group", e);
-            throw new AnalysisException("failed to get cloud compute group", 
e);
-        }
-        if (!Strings.isNullOrEmpty(cluster)) {
-            params.setCloudCluster(cluster);
+        if (Config.isCloudMode()) {
+            String cluster = "";
+            try {
+                cluster = ctx.getCloudCluster(false);
+            } catch (Exception e) {
+                LOG.warn("failed to get cloud compute group", e);
+                throw new AnalysisException("failed to get cloud compute 
group", e);
+            }
+            if (!Strings.isNullOrEmpty(cluster)) {
+                params.setCloudCluster(cluster);
+            }
         }
 
         // query options


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org