diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/statemachine/TaskFailureStateAction.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/statemachine/TaskFailureStateAction.java index 196e28dfac89..63cf2ba9941b 100644 --- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/statemachine/TaskFailureStateAction.java +++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/statemachine/TaskFailureStateAction.java @@ -135,9 +135,10 @@ public void killEventAction(final IWorkflowExecutionRunnable workflowExecutionRu // there is no task executor now, shouldn't call workflowExecutionGraph.isTaskExecutionRunnableActive() // it's better to call super.killedEventAction() direct if (taskExecutionRunnable.isTaskInstanceCanRetry() - // && workflowExecutionGraph.isTaskExecutionRunnableActive(taskExecutionRunnable) + // && workflowExecutionGraph.isTaskExecutionRunnableActive(taskExecutionRunnable) ) { - super.killedEventAction(workflowExecutionRunnable, taskExecutionRunnable, TaskKilledLifecycleEvent.of(taskExecutionRunnable)); + super.killedEventAction(workflowExecutionRunnable, taskExecutionRunnable, + TaskKilledLifecycleEvent.of(taskExecutionRunnable)); return; } logWarningIfCannotDoAction(taskExecutionRunnable, taskKillEvent);