[Enhancement] Allow CN to run script (#44982)

Signed-off-by: Binglin Chang <[email protected]> (cherry picked from commit ed6a72c) # Conflicts: # fe/fe-core/src/main/java/com/starrocks/qe/ExecuteScriptExecutor.java
StarRocks · Apr 29, 2024 · 1876b4e · 1876b4e
1 parent 9db4519
commit 1876b4e
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/fe/fe-core/src/main/java/com/starrocks/qe/ExecuteScriptExecutor.java b/fe/fe-core/src/main/java/com/starrocks/qe/ExecuteScriptExecutor.java
@@ -24,7 +24,7 @@
 import com.starrocks.rpc.BackendServiceClient;
 import com.starrocks.server.GlobalStateMgr;
 import com.starrocks.sql.ast.ExecuteScriptStmt;
-import com.starrocks.system.Backend;
+import com.starrocks.system.ComputeNode;
 import com.starrocks.thrift.TNetworkAddress;
 import groovy.lang.Binding;
 import groovy.lang.GroovyShell;
@@ -79,7 +79,11 @@ private static ShowResultSet executeFrontendScript(ExecuteScriptStmt stmt, Conne
     }
 
     private static ShowResultSet executeBackendScript(ExecuteScriptStmt stmt, ConnectContext ctx) throws UserException {
+<<<<<<< HEAD
         Backend be = GlobalStateMgr.getCurrentSystemInfo().getBackend(stmt.getBeId());
+=======
+        ComputeNode be = GlobalStateMgr.getCurrentState().getNodeMgr().getClusterInfo().getBackendOrComputeNode(stmt.getBeId());
+>>>>>>> ed6a72c431 ([Enhancement] Allow CN to run script (#44982))
         if (be == null) {
             throw new UserException("node not found: " + stmt.getBeId());
         }