wangbo commented on code in PR #49884:
URL: https://github.com/apache/doris/pull/49884#discussion_r2036412198
##########
fe/fe-core/src/main/java/org/apache/doris/load/routineload/KafkaTaskInfo.java:
##########
@@ -147,8 +148,9 @@ private TPipelineFragmentParams rePlan(RoutineLoadJob
routineLoadJob) throws Use
throw new UserException("can not find workload group, id="
+ wgId);
}
} else {
- tWgList = Env.getCurrentEnv().getWorkloadGroupMgr()
-
.getWorkloadGroupByUser(routineLoadJob.getUserIdentity(), false);
+ ConnectContext tmpCtx = new ConnectContext();
+
tmpCtx.setCurrentUserIdentity(routineLoadJob.getUserIdentity());
+ tWgList =
Env.getCurrentEnv().getWorkloadGroupMgr().getWorkloadGroup(tmpCtx);
}
if (tWgList.size() != 0) {
tExecPlanFragmentParams.setWorkloadGroups(tWgList);
Review Comment:
fe给be传的一直都是list，只不过之前list集合大小为1，现在可能会出现同名的wg在不同的分组上，比如resource tag就可以指定多个
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
