This is an automated email from the ASF dual-hosted git repository.

yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-2.1 by this push:
     new 581e168ee10 [Fix](executor)Fix normal workload group alter may failed 
#34356
581e168ee10 is described below

commit 581e168ee1066afa6543052724cda88ef8d7c66d
Author: wangbo <wan...@apache.org>
AuthorDate: Tue Apr 30 22:16:45 2024 +0800

    [Fix](executor)Fix normal workload group alter may failed #34356
---
 .../doris/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 bd2aaf932c9..b95217aca95 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() {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to