You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ji...@apache.org on 2022/10/23 03:39:13 UTC
[dolphinscheduler] branch 2.0.8-prepare updated: [BUG-12361] complement data by serial execution, after a failed process instance, subsequent process instances are not generated (#12488)
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 <wc...@gmail.com>
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:{}",