From 7c37a7f9feb9df0f3c92ccab4dfdb67e25d1bfae Mon Sep 17 00:00:00 2001 From: eye-gu <734164350@qq.com> Date: Wed, 9 Aug 2023 13:41:28 +0800 Subject: [PATCH] [Fix-14714][master] package task instance before put into cache (#14718) Co-authored-by: eye Co-authored-by: xiangzihao <460888207@qq.com> --- .../server/master/runner/WorkflowExecuteRunnable.java | 1 + 1 file changed, 1 insertion(+) 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 389834d25d..4d32ebbff3 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 @@ -849,6 +849,7 @@ public class WorkflowExecuteRunnable implements IWorkflowExecuteRunnable { } } + processService.packageTaskInstance(task, workflowInstance); validTaskMap.put(task.getTaskCode(), task.getId()); taskInstanceMap.put(task.getId(), task); taskCodeInstanceMap.put(task.getTaskCode(), task);