to #9595: fix param lost when execute failed task (#10646)

Co-authored-by: 宏豁 <honghuo.zw@alibaba-inc.com>
apache · Jun 28, 2022 · a86ce45 · a86ce45
1 parent 7d91ad3
commit a86ce45
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java b/...src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java
@@ -921,6 +921,10 @@ public void getPreVarPool(TaskInstance taskInstance, Set<String> preTask) {
             if (allProperty.size() > 0) {
                 taskInstance.setVarPool(JSONUtils.toJsonString(allProperty.values()));
             }
+        } else {
+            if (StringUtils.isNotEmpty(processInstance.getVarPool())) {
+                taskInstance.setVarPool(processInstance.getVarPool());
+            }
         }
     }