From 234f399488e7fb0937cbf322c928f7abb9eb8365 Mon Sep 17 00:00:00 2001 From: xiangzihao <460888207@qq.com> Date: Sat, 19 Feb 2022 21:38:58 +0800 Subject: [PATCH] remove worker group lowercase (#8448) --- .../server/master/registry/ServerNodeManager.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/ServerNodeManager.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/ServerNodeManager.java index c9c9ce5d3d..11f013ed31 100644 --- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/ServerNodeManager.java +++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/ServerNodeManager.java @@ -363,7 +363,6 @@ public class ServerNodeManager implements InitializingBean { private void syncWorkerGroupNodes(String workerGroup, Collection nodes) { workerGroupLock.lock(); try { - workerGroup = workerGroup.toLowerCase(); Set workerNodes = workerGroupNodes.getOrDefault(workerGroup, new HashSet<>()); workerNodes.clear(); workerNodes.addAll(nodes); @@ -389,7 +388,6 @@ public class ServerNodeManager implements InitializingBean { if (StringUtils.isEmpty(workerGroup)) { workerGroup = Constants.DEFAULT_WORKER_GROUP; } - workerGroup = workerGroup.toLowerCase(); Set nodes = workerGroupNodes.get(workerGroup); if (CollectionUtils.isNotEmpty(nodes)) { return Collections.unmodifiableSet(nodes);