You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by we...@apache.org on 2023/03/25 04:27:11 UTC
[dolphinscheduler] branch dev updated: Fix retry task instance will loss varpool (#13791)
This is an automated email from the ASF dual-hosted git repository.
wenjun pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new d91bdeff37 Fix retry task instance will loss varpool (#13791)
d91bdeff37 is described below
commit d91bdeff37cc2bfe537afc0d22d92288a84620e7
Author: Wenjun Ruan <we...@apache.org>
AuthorDate: Sat Mar 25 12:26:59 2023 +0800
Fix retry task instance will loss varpool (#13791)
---
.../dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java
index 7e594f77fe..3951f121f5 100644
--- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java
+++ b/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
newTaskInstance.setState(taskInstance.getState());
newTaskInstance.setEndTime(taskInstance.getEndTime());
+ newTaskInstance.setVarPool(taskInstance.getVarPool());
if (taskInstance.getState() == TaskExecutionStatus.NEED_FAULT_TOLERANCE) {
newTaskInstance.setAppLink(taskInstance.getAppLink());
@@ -1162,6 +1163,7 @@ public class WorkflowExecuteRunnable implements Callable<WorkflowSubmitStatue> {
newTaskInstance.setRetryTimes(taskInstance.getRetryTimes());
newTaskInstance.setState(taskInstance.getState());
newTaskInstance.setAppLink(taskInstance.getAppLink());
+ newTaskInstance.setVarPool(taskInstance.getVarPool());
return newTaskInstance;
}