taskInstance variables add volatile

5 years ago · 5af90ba185
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
@ -82,7 +82,7 @@ public class FetchTaskThread implements Runnable{
    /**
     *  task instance
     */
-    private TaskInstance taskInstance;
+    private volatile TaskInstance taskInstance;
    /**
     * task instance id