[FIX-#4084][server]cherry pick from dev to fix taskInstance state cha…

…nge error (#4171) Co-authored-by: CalvinKirs <acm_master@163.com>
apache · Dec 8, 2020 · 6d3293c · 6d3293c
1 parent d53991e
commit 6d3293c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...n/java/org/apache/dolphinscheduler/server/master/processor/queue/TaskResponseService.java b/...n/java/org/apache/dolphinscheduler/server/master/processor/queue/TaskResponseService.java
@@ -134,7 +134,7 @@ private void persist(TaskResponseEvent taskResponseEvent){
             case ACK:
                 try {
                     TaskInstance taskInstance = processService.findTaskInstanceById(taskResponseEvent.getTaskInstanceId());
-                    if (taskInstance != null){
+                    if (taskInstance != null && !taskInstance.getState().typeIsFinished()) {
                         processService.changeTaskState(taskResponseEvent.getState(),
                                 taskResponseEvent.getStartTime(),
                                 taskResponseEvent.getWorkerAddress(),