Browse Source

update TaskInstance get

qiaozhanwei 5 years ago
parent
commit
b6343ee9b6

+ 2 - 2
escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java

@@ -82,7 +82,7 @@ public class FetchTaskThread implements Runnable{
     /**
      *  task instance
      */
-    private volatile TaskInstance taskInstance;
+    private  TaskInstance taskInstance;
 
     /**
      * task instance id
@@ -175,7 +175,7 @@ public class FetchTaskThread implements Runnable{
                     taskInstId = Integer.parseInt(taskQueueStr.split(Constants.UNDERLINE)[3]);
 
                     // get task instance relation
-                    TaskInstance taskInstance = processDao.getTaskInstanceRelationByTaskId(taskInstId);
+                    taskInstance = processDao.getTaskInstanceRelationByTaskId(taskInstId);
 
                     Tenant tenant = processDao.getTenantForProcess(taskInstance.getProcessInstance().getTenantId(),
                             taskInstance.getProcessDefine().getUserId());