This is an automated email from the ASF dual-hosted git repository.
jinyleechina pushed a commit to branch 2.0.8-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/2.0.8-prepare by this push:
new b2d682ed31 [BUG-12361] complement data by serial execution, after a
failed process instance, subsequent process instances are not generated (#12488)
b2d682ed31 is described below
commit b2d682ed3126d41d3bc0349879d3e0f2f8a4b9c8
Author: Molin Wang <[email protected]>
AuthorDate: Sun Oct 23 11:39:07 2022 +0800
[BUG-12361] complement data by serial execution, after a failed process
instance, subsequent process instances are not generated (#12488)
---
.../dolphinscheduler/server/master/runner/WorkflowExecuteThread.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java
b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java
index 269d921aba..4d84227c40 100644
---
a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java
+++
b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java
@@ -539,9 +539,9 @@ public class WorkflowExecuteThread implements Runnable {
return true;
}
int index = complementListDate.indexOf(scheduleDate);
- if (index >= complementListDate.size() - 1 ||
!processInstance.getState().typeIsSuccess()) {
+ if (index >= complementListDate.size() - 1) {
logger.info("process complement end. process id:{}",
processInstance.getId());
- // complement data ends || no success
+ // complement data ends
return true;
}
logger.info("process complement continue. process id:{}, schedule
time:{} complementListDate:{}",
