[dolphinscheduler] branch 2.0.2-prepare updated: fix workflow copy (#7659) (#7663)

[caishunfeng]

This is an automated email from the ASF dual-hosted git repository.

caishunfeng pushed a commit to branch 2.0.2-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/2.0.2-prepare by this push:
     new affb2a3  fix workflow copy (#7659) (#7663)
affb2a3 is described below

commit affb2a3f0f8c01e7607286dd7514bf4589c6b2eb
Author: wind <caishunf...@users.noreply.github.com>
AuthorDate: Tue Dec 28 11:33:14 2021 +0800

    fix workflow copy (#7659) (#7663)
    
    Co-authored-by: caishunfeng <534328...@qq.com>
    
    Co-authored-by: caishunfeng <534328...@qq.com>
---
 .../dolphinscheduler/service/process/ProcessService.java      | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git 
a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java
 
b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java
index cc968f9..72abed7 100644
--- 
a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java
+++ 
b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java
@@ -2302,11 +2302,14 @@ public class ProcessService {
             
processTaskRelationLog.setProcessDefinitionCode(processDefinitionCode);
             
processTaskRelationLog.setProcessDefinitionVersion(processDefinitionVersion);
             if (taskDefinitionLogMap != null) {
-                TaskDefinitionLog taskDefinitionLog = 
taskDefinitionLogMap.get(processTaskRelationLog.getPreTaskCode());
-                if (taskDefinitionLog != null) {
-                    
processTaskRelationLog.setPreTaskVersion(taskDefinitionLog.getVersion());
+                TaskDefinitionLog preTaskDefinitionLog = 
taskDefinitionLogMap.get(processTaskRelationLog.getPreTaskCode());
+                if (preTaskDefinitionLog != null) {
+                    
processTaskRelationLog.setPreTaskVersion(preTaskDefinitionLog.getVersion());
+                }
+                TaskDefinitionLog postTaskDefinitionLog = 
taskDefinitionLogMap.get(processTaskRelationLog.getPostTaskCode());
+                if (postTaskDefinitionLog != null) {
+                    
processTaskRelationLog.setPostTaskVersion(postTaskDefinitionLog.getVersion());
                 }
-                
processTaskRelationLog.setPostTaskVersion(taskDefinitionLogMap.get(processTaskRelationLog.getPostTaskCode()).getVersion());
             }
             processTaskRelationLog.setCreateTime(now);
             processTaskRelationLog.setUpdateTime(now);