lenboo commented on a change in pull request #6477:
URL: https://github.com/apache/dolphinscheduler/pull/6477#discussion_r725607182



##########
File path: 
dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java
##########
@@ -878,13 +875,6 @@ private ProcessInstance constructProcessInstance(Command 
command, String host) {
                 runStatus = processInstance.getState();
                 break;
             case COMPLEMENT_DATA:
-                // delete all the valid tasks when complement data
-                List<TaskInstance> taskInstanceList = 
this.findValidTaskListByProcessId(processInstance.getId());

Review comment:
       maybe this process is necessary when we rerun the complement data 
process instance.




-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to