From a7ecc5a8b31d63bb71615d59aeffddc60e59f5aa Mon Sep 17 00:00:00 2001 From: JieguangZhou Date: Mon, 5 Dec 2022 21:22:51 +0800 Subject: [PATCH] fix retry task failure (#13077) --- .../server/master/event/TaskRetryStateEventHandler.java | 2 +- .../server/master/runner/StateWheelExecuteThread.java | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskRetryStateEventHandler.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskRetryStateEventHandler.java index 4a55b6b430..d4ab7fc948 100644 --- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskRetryStateEventHandler.java +++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskRetryStateEventHandler.java @@ -39,7 +39,7 @@ public class TaskRetryStateEventHandler implements StateEventHandler { StateEvent stateEvent) throws StateEventHandleException { TaskStateEvent taskStateEvent = (TaskStateEvent) stateEvent; - logger.info("Handle task instance retry event, taskInstanceId: {}", taskStateEvent.getTaskInstanceId()); + logger.info("Handle task instance retry event, taskCode: {}", taskStateEvent.getTaskCode()); TaskMetrics.incTaskInstanceByState("retry"); Map waitToRetryTaskInstanceMap = workflowExecuteRunnable.getWaitToRetryTaskInstanceMap(); diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/StateWheelExecuteThread.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/StateWheelExecuteThread.java index ad1838862d..fec027935f 100644 --- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/StateWheelExecuteThread.java +++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/StateWheelExecuteThread.java @@ -422,7 +422,6 @@ public class StateWheelExecuteThread extends BaseDaemonThread { private void addTaskRetryEvent(TaskInstance taskInstance) { TaskStateEvent stateEvent = TaskStateEvent.builder() .processInstanceId(taskInstance.getProcessInstanceId()) - .taskInstanceId(taskInstance.getId()) .taskCode(taskInstance.getTaskCode()) .status(TaskExecutionStatus.RUNNING_EXECUTION) .type(StateEventType.TASK_RETRY)