From 581e168ee1066afa6543052724cda88ef8d7c66d Mon Sep 17 00:00:00 2001 From: wangbo Date: Tue, 30 Apr 2024 22:16:45 +0800 Subject: [PATCH] [Fix](executor)Fix normal workload group alter may failed #34356 --- .../resource/workloadgroup/WorkloadGroupMgr.java | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 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 bd2aaf932c..b95217aca9 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 @@ -158,8 +158,19 @@ public class WorkloadGroupMgr implements Writable, GsonPostProcessable { properties.put(WorkloadGroup.ENABLE_MEMORY_OVERCOMMIT, "true"); WorkloadGroup defaultWorkloadGroup = new WorkloadGroup(DEFAULT_GROUP_ID.longValue(), DEFAULT_GROUP_NAME, properties); - nameToWorkloadGroup.put(DEFAULT_GROUP_NAME, defaultWorkloadGroup); - idToWorkloadGroup.put(defaultWorkloadGroup.getId(), defaultWorkloadGroup); + boolean nameIsNull = true; + if (!nameToWorkloadGroup.containsKey(DEFAULT_GROUP_NAME)) { + nameToWorkloadGroup.put(DEFAULT_GROUP_NAME, defaultWorkloadGroup); + nameIsNull = false; + } + boolean idIsNull = true; + if (!idToWorkloadGroup.containsKey(DEFAULT_GROUP_ID)) { + idToWorkloadGroup.put(defaultWorkloadGroup.getId(), defaultWorkloadGroup); + idIsNull = false; + } + if ((nameIsNull && !idIsNull) || (!nameIsNull && idIsNull)) { + LOG.info("idMap({}) diff nameMap({})", nameIsNull, idIsNull); + } } private void readLock() {