yiguolei commented on code in PR #48187:
URL: https://github.com/apache/doris/pull/48187#discussion_r1974726402
##########
fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadJob.java:
##########
@@ -231,6 +236,29 @@ brokerFileGroups, getDeadlineMs(), getExecMemLimit(),
UUID uuid = UUID.randomUUID();
TUniqueId loadId = new TUniqueId(uuid.getMostSignificantBits(),
uuid.getLeastSignificantBits());
+ ConnectContext context = ConnectContext.get();
+ if (context == null) {
+ context = new ConnectContext();
+ context.setThreadLocalInfo();
+ }
+
+ String currentUser = getUserInfo().getQualifiedUser();
+ ComputeGroup computeGroup = null;
+ // user is null or get an invalid compute group should not be normal
case,
+ // broker load job can get all backends when meets it.
+ if (StringUtils.isEmpty(currentUser)) {
+ computeGroup =
Env.getCurrentEnv().getComputeGroupMgr().getAllBackendComputeGroup();
+ LOG.warn("can not find user in broker load, then skip compute
group");
+ } else {
+ computeGroup =
Env.getCurrentEnv().getAuth().getComputeGroup(currentUser);
+ if (computeGroup == ComputeGroup.INVALID_COMPUTE_GROUP) {
+ LOG.warn(ComputeGroup.INVALID_COMPUTE_GROUP_ERR_MSG);
Review Comment:
日志打印的太简单了，看了日志也不明白啥问题，
--
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
