From bb12fa368efd99e0802c8c7d3e71a015adf22ffa Mon Sep 17 00:00:00 2001 From: Binglin Chang Date: Mon, 29 Apr 2024 22:17:51 +0800 Subject: [PATCH] [Enhancement] Allow CN to run script (#44982) Signed-off-by: Binglin Chang (cherry picked from commit ed6a72c431601f985271861de5e92bd40aab7e79) --- .../src/main/java/com/starrocks/qe/ExecuteScriptExecutor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 index 389d4db6be6db9..0f1458ec0736f3 100644 --- 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,7 @@ private static ShowResultSet executeFrontendScript(ExecuteScriptStmt stmt, Conne } private static ShowResultSet executeBackendScript(ExecuteScriptStmt stmt, ConnectContext ctx) throws UserException { - Backend be = GlobalStateMgr.getCurrentSystemInfo().getBackend(stmt.getBeId()); + ComputeNode be = GlobalStateMgr.getCurrentSystemInfo().getBackendOrComputeNode(stmt.getBeId()); if (be == null) { throw new UserException("node not found: " + stmt.getBeId()); }