Browse Source

Fix retry task instance will loss varpool (#13791)

3.2.0-release
Wenjun Ruan 2 years ago committed by GitHub
parent
commit
d91bdeff37
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 2
      dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java

2
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java

@ -1135,6 +1135,7 @@ public class WorkflowExecuteRunnable implements Callable<WorkflowSubmitStatue> {
// todo relative function: TaskInstance.retryTaskIntervalOverTime // todo relative function: TaskInstance.retryTaskIntervalOverTime
newTaskInstance.setState(taskInstance.getState()); newTaskInstance.setState(taskInstance.getState());
newTaskInstance.setEndTime(taskInstance.getEndTime()); newTaskInstance.setEndTime(taskInstance.getEndTime());
newTaskInstance.setVarPool(taskInstance.getVarPool());
if (taskInstance.getState() == TaskExecutionStatus.NEED_FAULT_TOLERANCE) { if (taskInstance.getState() == TaskExecutionStatus.NEED_FAULT_TOLERANCE) {
newTaskInstance.setAppLink(taskInstance.getAppLink()); newTaskInstance.setAppLink(taskInstance.getAppLink());
@ -1162,6 +1163,7 @@ public class WorkflowExecuteRunnable implements Callable<WorkflowSubmitStatue> {
newTaskInstance.setRetryTimes(taskInstance.getRetryTimes()); newTaskInstance.setRetryTimes(taskInstance.getRetryTimes());
newTaskInstance.setState(taskInstance.getState()); newTaskInstance.setState(taskInstance.getState());
newTaskInstance.setAppLink(taskInstance.getAppLink()); newTaskInstance.setAppLink(taskInstance.getAppLink());
newTaskInstance.setVarPool(taskInstance.getVarPool());
return newTaskInstance; return newTaskInstance;
} }

Loading…
Cancel
Save