You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ke...@apache.org on 2021/12/07 12:06:02 UTC
[dolphinscheduler] branch dev updated: to #7228 (#7249)
This is an automated email from the ASF dual-hosted git repository.
kerwin 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 f577b5b to #7228 (#7249)
f577b5b is described below
commit f577b5bd30ea86df3cd07af04cef358db52d0f29
Author: zwZjut <zw...@163.com>
AuthorDate: Tue Dec 7 20:05:57 2021 +0800
to #7228 (#7249)
Co-authored-by: honghuo.zw <ho...@alibaba-inc.com>
---
.../dolphinscheduler/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 fe60ec6..a974e6d 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();