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);