Browse Source

[Fix-14714][master] package task instance before put into cache (#14718)

Co-authored-by: eye <eye.gu@aloudata.com>
Co-authored-by: xiangzihao <460888207@qq.com>
3.2.1-prepare
eye-gu 1 year ago committed by GitHub
parent
commit
7c37a7f9fe
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 1
      dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java

1
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()); validTaskMap.put(task.getTaskCode(), task.getId());
taskInstanceMap.put(task.getId(), task); taskInstanceMap.put(task.getId(), task);
taskCodeInstanceMap.put(task.getTaskCode(), task); taskCodeInstanceMap.put(task.getTaskCode(), task);

Loading…
Cancel
Save