[dolphinscheduler] branch dev updated: [Improvement-11468] Support re running historical version workflow (#11489)

[leonbao]

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

leonbao pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new ebdf903dcc [Improvement-11468] Support re running historical version 
workflow (#11489)
ebdf903dcc is described below

commit ebdf903dcc0e770ebf35167a5802cdd5ba229f61
Author: insist777 <84278047+insist...@users.noreply.github.com>
AuthorDate: Thu Aug 18 09:46:54 2022 +0800

    [Improvement-11468] Support re running historical version workflow (#11489)
    
    * Support re running historical version workflow
    
     Support re running historical version workflow
    
    * Update ExecutorServiceImpl.java
    
    * Update ExecutorServiceImpl.java
---
 .../dolphinscheduler/api/service/impl/ExecutorServiceImpl.java       | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java
 
b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java
index 4502fcd8ec..86483f484d 100644
--- 
a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java
+++ 
b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java
@@ -324,7 +324,9 @@ public class ExecutorServiceImpl extends BaseServiceImpl 
implements ExecutorServ
     }
 
     /**
-     * do action to process instance：pause, stop, repeat, recover from pause, 
recover from stop
+     * do action to process instance：pause, stop, repeat, recover from pause, 
recover from stop，rerun failed task
+
+
      *
      * @param loginUser         login user
      * @param projectCode       project code
@@ -358,6 +360,7 @@ public class ExecutorServiceImpl extends BaseServiceImpl 
implements ExecutorServ
         ProcessDefinition processDefinition =
                 
processService.findProcessDefinition(processInstance.getProcessDefinitionCode(),
                         processInstance.getProcessDefinitionVersion());
+        processDefinition.setReleaseState(ReleaseState.ONLINE);
         if (executeType != ExecuteType.STOP && executeType != 
ExecuteType.PAUSE) {
             result =
                     checkProcessDefinitionValid(projectCode, processDefinition,