From b6343ee9b6337ce44be69f52a10aa24fabd379e1 Mon Sep 17 00:00:00 2001 From: qiaozhanwei <825193156@qq.com> Date: Thu, 25 Jul 2019 19:29:26 +0800 Subject: [PATCH] update TaskInstance get --- .../cn/escheduler/server/worker/runner/FetchTaskThread.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 053fad6af1..f899c62d08 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 @@ -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());