From f577b5bd30ea86df3cd07af04cef358db52d0f29 Mon Sep 17 00:00:00 2001
From: zwZjut <zw15068835817@163.com>
Date: Tue, 7 Dec 2021 20:05:57 +0800
Subject: [PATCH] to #7228 (#7249)

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

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 fe60ec61d2..a974e6d31b 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
@@ -832,6 +832,7 @@ public class WorkflowExecuteThread implements Runnable {
                         taskInstance.getId(), taskInstance.getName());
                 return null;
             }
+            validTaskMap.put(Long.toString(taskInstance.getTaskCode()), taskInstance.getId());
             taskInstanceMap.put(taskInstance.getId(), taskInstance);
             activeTaskProcessorMaps.put(taskInstance.getId(), taskProcessor);
             taskProcessor.run();