This is an automated email from the ASF dual-hosted git repository.
hellostephen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 60cfd23c2e3 [Fix][wg]Fix cloud workload group test error (#52574)
60cfd23c2e3 is described below
commit 60cfd23c2e330bd2b09a811e7146320d2a43eb57
Author: wangbo <[email protected]>
AuthorDate: Tue Jul 1 16:05:22 2025 +0800
[Fix][wg]Fix cloud workload group test error (#52574)
### What problem does this PR solve?
Fix misused compute group name,it should use cg id to identify a
workload group instead of a name
---
.../org/apache/doris/resource/workloadgroup/WorkloadGroupMgr.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/resource/workloadgroup/WorkloadGroupMgr.java
b/fe/fe-core/src/main/java/org/apache/doris/resource/workloadgroup/WorkloadGroupMgr.java
index 95f0a79ff05..d8e524fc908 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/resource/workloadgroup/WorkloadGroupMgr.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/resource/workloadgroup/WorkloadGroupMgr.java
@@ -375,9 +375,8 @@ public class WorkloadGroupMgr extends MasterDaemon
implements Writable, GsonPost
throw new DdlException("Alter workload group should contain at
least one property");
}
- String cgName = cg.getName();
WorkloadGroup newWorkloadGroup;
- WorkloadGroupKey wgKey = WorkloadGroupKey.get(cgName,
workloadGroupName);
+ WorkloadGroupKey wgKey = WorkloadGroupKey.get(cg.getId(),
workloadGroupName);
writeLock();
try {
// get 0 idx here because there can only be one wg in cg with
specify wg name.
@@ -386,7 +385,7 @@ public class WorkloadGroupMgr extends MasterDaemon
implements Writable, GsonPost
throw new RuntimeException(
"Unexpected error: find " + ret.size() + " workload
group " + workloadGroupName
+ " in compute group "
- + cgName);
+ + cg.getName());
}
WorkloadGroup currentWorkloadGroup = ret.get(0);
newWorkloadGroup =
WorkloadGroup.copyAndUpdate(currentWorkloadGroup, properties);
@@ -397,7 +396,7 @@ public class WorkloadGroupMgr extends MasterDaemon
implements Writable, GsonPost
} finally {
writeUnlock();
}
- LOG.info("Alter workload group {} for compute group {} success: {}",
newWorkloadGroup, cgName);
+ LOG.info("Alter workload group {} for compute group {} success: {}",
newWorkloadGroup, cg.getName());
}
public void dropWorkloadGroup(DropWorkloadGroupStmt stmt) throws
DdlException {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
