fix task instance status judgment error

4 years ago · c902268021
1 changed files with 1 additions and 1 deletions
--- 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
@ -138,7 +138,7 @@ public class TaskResponseService {
            case ACK:
                try {
                    TaskInstance taskInstance = processService.findTaskInstanceById(taskResponseEvent.getTaskInstanceId());
-                    if (taskInstance != null && ExecutionStatus.SUCCESS.getCode() != taskInstance.getState().getCode()) {
+                    if (taskInstance != null && !taskInstance.getState().typeIsFinished()) {
                        processService.changeTaskState(taskInstance, taskResponseEvent.getState(),
                            taskResponseEvent.getStartTime(),
                            taskResponseEvent.getWorkerAddress(),