update worker group

5 years ago · c2f8e8ef3b
1 changed files with 1 additions and 1 deletions
--- a/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java
+++ b/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java
@ -114,7 +114,7 @@ public class FetchTaskThread implements Runnable{
        if(taskWorkerGroupId <= 0){
            return true;
        }
-        WorkerGroup workerGroup = processDao.queryWorkerGroupById(taskInstance.getWorkerGroupId());
+        WorkerGroup workerGroup = processDao.queryWorkerGroupById(taskWorkerGroupId);
        if(workerGroup == null ){
            logger.info("task {} cannot find the worker group, use all worker instead.", taskInstance.getId());
            return true;