(doris) branch master updated: [monir] remove unused cluster code (#31360)

[yiguolei]

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

yiguolei 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 c2fe99f7c2b [monir] remove unused cluster code (#31360)
c2fe99f7c2b is described below

commit c2fe99f7c2be5351e1b9f117151142041db7ea71
Author: Mingyu Chen <morning...@163.com>
AuthorDate: Sat Feb 24 16:23:20 2024 +0800

    [monir] remove unused cluster code (#31360)
    
    * [monir] remove unused cluster code
    
    * 2
---
 .../datasource/hive/event/MetastoreEventsProcessor.java      |  2 --
 .../src/main/java/org/apache/doris/qe/ConnectContext.java    | 12 +-----------
 2 files changed, 1 insertion(+), 13 deletions(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/MetastoreEventsProcessor.java
 
b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/MetastoreEventsProcessor.java
index e5db75ff9f3..5ca94866bb4 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/MetastoreEventsProcessor.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/event/MetastoreEventsProcessor.java
@@ -30,7 +30,6 @@ import org.apache.doris.datasource.hive.HMSExternalCatalog;
 import org.apache.doris.qe.ConnectContext;
 import org.apache.doris.qe.MasterOpExecutor;
 import org.apache.doris.qe.OriginStatement;
-import org.apache.doris.system.SystemInfoService;
 
 import com.google.common.collect.Maps;
 import org.apache.commons.lang3.StringUtils;
@@ -320,7 +319,6 @@ public class MetastoreEventsProcessor extends MasterDaemon {
         ctx.setQualifiedUser(UserIdentity.ROOT.getQualifiedUser());
         ctx.setCurrentUserIdentity(UserIdentity.ROOT);
         ctx.setEnv(Env.getCurrentEnv());
-        ctx.setCluster(SystemInfoService.DEFAULT_CLUSTER);
         MasterOpExecutor masterOpExecutor = new MasterOpExecutor(originStmt, 
ctx,
                 RedirectStatus.FORWARD_WITH_SYNC, false);
         if (LOG.isDebugEnabled()) {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java 
b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java
index dcf618248dd..484d3c47afb 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java
@@ -142,8 +142,6 @@ public class ConnectContext {
     protected volatile long currentDbId = -1;
     // Transaction
     protected volatile TransactionEntry txnEntry = null;
-    // cluster name
-    protected volatile String clusterName = "";
     // used for ShowSqlAction which don't allow a user account
     protected volatile boolean noAuth = false;
     // username@host of current login user
@@ -848,14 +846,6 @@ public class ConnectContext {
         return queryId;
     }
 
-    public String getClusterName() {
-        return clusterName;
-    }
-
-    public void setCluster(String clusterName) {
-        this.clusterName = clusterName;
-    }
-
     public String getSqlHash() {
         return sqlHash;
     }
@@ -1126,7 +1116,7 @@ public class ConnectContext {
             AtomicBoolean hasAliveBe = new AtomicBoolean(false);
             bes.stream().filter(Backend::isAlive).findAny().ifPresent(backend 
-> {
                 if (LOG.isDebugEnabled()) {
-                    LOG.debug("get a clusterName {}, it's has more than one 
alive be {}", clusterName, backend);
+                    LOG.debug("get a clusterName {}, it's has more than one 
alive be {}", cloudClusterName, backend);
                 }
                 hasAliveBe.set(true);
             });


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