diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java index 703830cba00218..0113d9d1d5ecf9 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java @@ -709,6 +709,9 @@ public TMasterOpResult proxyExecute(TMasterOpRequest request) throws TException ctx.setUserVars(userVariableFromThrift(request.getUserVariables())); } + // set resource tag + ctx.setResourceTags(Env.getCurrentEnv().getAuth().getResourceTags(ctx.qualifiedUser)); + ctx.setThreadLocalInfo(); StmtExecutor executor = null; try {