From a86ce4544117f8cd4a8d0e50073bf2e4e3fe275c Mon Sep 17 00:00:00 2001
From: zwZjut <zw15068835817@163.com>
Date: Tue, 28 Jun 2022 13:40:24 +0800
Subject: [PATCH] to #9595: fix param lost when execute failed task (#10646)
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Co-authored-by: 宏豁 <honghuo.zw@alibaba-inc.com>
---
 .../server/master/runner/WorkflowExecuteThread.java           | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java
index 580286852b3b..76e44e43e088 100644
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java
+++ b/dolphinscheduler-server/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());
+            }
         }
     }