diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkerGroupServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkerGroupServiceImpl.java index cef5e2bfa1736af95952d8024ee7b3fac33a8457..fa94add1fc6d7ac0f101e59754b01de77214e857 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkerGroupServiceImpl.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/WorkerGroupServiceImpl.java @@ -118,12 +118,12 @@ public class WorkerGroupServiceImpl extends BaseServiceImpl implements WorkerGro putMsg(result, Status.WORKER_ADDRESS_INVALID, invalidAddr); return result; } - handleDefaultWorkGroup(workerGroupMapper, workerGroup, loginUser, otherParamsJson); + saveWorkGroup(workerGroupMapper, workerGroup, loginUser, otherParamsJson); putMsg(result, Status.SUCCESS); return result; } - protected void handleDefaultWorkGroup(WorkerGroupMapper workerGroupMapper, WorkerGroup workerGroup, User loginUser, String otherParamsJson) { + protected void saveWorkGroup(WorkerGroupMapper workerGroupMapper, WorkerGroup workerGroup, User loginUser, String otherParamsJson) { if (workerGroup.getId() != 0) { workerGroupMapper.updateById(workerGroup); } else { @@ -152,6 +152,10 @@ public class WorkerGroupServiceImpl extends BaseServiceImpl implements WorkerGro } } } + // skip default group name check + if (Constants.DEFAULT.equals(workerGroup.getName())) { + return false; + } // check zookeeper String workerGroupPath = Constants.REGISTRY_DOLPHINSCHEDULER_WORKERS + Constants.SINGLE_SLASH + workerGroup.getName(); return registryClient.exists(workerGroupPath);