From 6d3293cffc469101d5bbb9e8d39618db0c19e3cf Mon Sep 17 00:00:00 2001 From: lgcareer <18610854716@163.com> Date: Tue, 8 Dec 2020 10:28:30 +0800 Subject: [PATCH] [FIX-#4084][server]cherry pick from dev to fix taskInstance state change error (#4171) Co-authored-by: CalvinKirs --- .../server/master/processor/queue/TaskResponseService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/processor/queue/TaskResponseService.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/processor/queue/TaskResponseService.java index f365db70bb..4cd7e8b848 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/processor/queue/TaskResponseService.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/processor/queue/TaskResponseService.java @@ -134,7 +134,7 @@ public class TaskResponseService { 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(),