Bläddra i källkod

Merge branch 'dev-1.3.0' of https://github.com/apache/incubator-dolphinscheduler into dev-1.3.0

break60 5 år sedan
förälder
incheckning
d58affaf59

+ 4 - 1
dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java

@@ -634,6 +634,7 @@ public class ProcessService {
                     taskInstance.setFlag(Flag.NO);
                     taskInstance.setFlag(Flag.NO);
                     this.updateTaskInstance(taskInstance);
                     this.updateTaskInstance(taskInstance);
                 }
                 }
+                initComplementDataParam(processDefinition, processInstance, cmdParam);
                 break;
                 break;
             case REPEAT_RUNNING:
             case REPEAT_RUNNING:
                 // delete the recover task names from command parameter
                 // delete the recover task names from command parameter
@@ -690,7 +691,9 @@ public class ProcessService {
 
 
         Date startComplementTime = DateUtils.parse(cmdParam.get(CMDPARAM_COMPLEMENT_DATA_START_DATE),
         Date startComplementTime = DateUtils.parse(cmdParam.get(CMDPARAM_COMPLEMENT_DATA_START_DATE),
                 YYYY_MM_DD_HH_MM_SS);
                 YYYY_MM_DD_HH_MM_SS);
-        processInstance.setScheduleTime(startComplementTime);
+        if(Flag.NO == processInstance.getIsSubProcess()) {
+            processInstance.setScheduleTime(startComplementTime);
+        }
         processInstance.setGlobalParams(ParameterUtils.curingGlobalParams(
         processInstance.setGlobalParams(ParameterUtils.curingGlobalParams(
                 processDefinition.getGlobalParamMap(),
                 processDefinition.getGlobalParamMap(),
                 processDefinition.getGlobalParamList(),
                 processDefinition.getGlobalParamList(),