From c2f8e8ef3bef5eb4da3159649631e46b9f37e717 Mon Sep 17 00:00:00 2001
From: baoliang <baoliang@analysys.com.cn>
Date: Tue, 23 Apr 2019 16:07:36 +0800
Subject: [PATCH] update worker group

---
 .../cn/escheduler/server/worker/runner/FetchTaskThread.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 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
index 0390cae0c0..f163364b06 100644
--- 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;