fix comment

apache · Dec 9, 2024 · 0f05c50 · 0f05c50
1 parent 399771e
commit 0f05c50
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/...r-worker/src/main/java/org/apache/dolphinscheduler/server/worker/config/WorkerConfig.java b/...r-worker/src/main/java/org/apache/dolphinscheduler/server/worker/config/WorkerConfig.java
@@ -56,13 +56,6 @@ public class WorkerConfig implements Validator {
 
     private PhysicalTaskConfig physicalTaskConfig = new PhysicalTaskConfig();
 
-    public String getGroup() {
-        if (StringUtils.isEmpty(group)) {
-            return "default";
-        }
-        return group;
-    }
-
     @Override
     public boolean supports(Class<?> clazz) {
         return WorkerConfig.class.isAssignableFrom(clazz);
@@ -80,6 +73,11 @@ public void validate(Object target, Errors errors) {
 
         workerConfig.setWorkerRegistryPath(
                 RegistryNodeType.WORKER.getRegistryPath() + "/" + workerConfig.getWorkerAddress());
+
+        if (StringUtils.isEmpty(group)) {
+            workerConfig.setGroup("default");
+        }
+
         printConfig();
     }