natas_hw
/
dolphinscheduler0701
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix retry task failure (#13077)

This commit is contained in:
JieguangZhou 2022-12-05 21:22:51 +08:00 committed by GitHub
parent fed1e85fb8
commit a7ecc5a8b3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskRetryStateEventHandler.java
View File

@ -39,7 +39,7 @@ public class TaskRetryStateEventHandler implements StateEventHandler {
StateEvent stateEvent) throws StateEventHandleException { StateEvent stateEvent) throws StateEventHandleException {
TaskStateEvent taskStateEvent = (TaskStateEvent) stateEvent; 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"); TaskMetrics.incTaskInstanceByState("retry");
Map<Long, TaskInstance> waitToRetryTaskInstanceMap = workflowExecuteRunnable.getWaitToRetryTaskInstanceMap(); Map<Long, TaskInstance> waitToRetryTaskInstanceMap = workflowExecuteRunnable.getWaitToRetryTaskInstanceMap();

1
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/StateWheelExecuteThread.java
View File

@ -422,7 +422,6 @@ public class StateWheelExecuteThread extends BaseDaemonThread {
private void addTaskRetryEvent(TaskInstance taskInstance) { private void addTaskRetryEvent(TaskInstance taskInstance) {
TaskStateEvent stateEvent = TaskStateEvent.builder() TaskStateEvent stateEvent = TaskStateEvent.builder()
.processInstanceId(taskInstance.getProcessInstanceId()) .processInstanceId(taskInstance.getProcessInstanceId())
.taskInstanceId(taskInstance.getId())
.taskCode(taskInstance.getTaskCode()) .taskCode(taskInstance.getTaskCode())
.status(TaskExecutionStatus.RUNNING_EXECUTION) .status(TaskExecutionStatus.RUNNING_EXECUTION)
.type(StateEventType.TASK_RETRY) .type(StateEventType.TASK_RETRY)