This is an automated email from the ASF dual-hosted git repository.
kerwin pushed a commit to branch 3.1.9-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/3.1.9-prepare by this push:
new ff5fecdfd5 cherry-pick [improve-#13045] after a submit failure, stop
the processInstance to avoid an endless loop #13051
ff5fecdfd5 is described below
commit ff5fecdfd52804bd6ca5c711d469b68971f03979
Author: fuchanghai <[email protected]>
AuthorDate: Mon Feb 20 14:10:59 2023 +0800
cherry-pick [improve-#13045] after a submit failure, stop the
processInstance to avoid an endless loop
#13051
---
.../dolphinscheduler/server/master/event/WorkflowStartEventHandler.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStartEventHandler.java
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStartEventHandler.java
index 0b43ae33fd..e130b13b08 100644
---
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStartEventHandler.java
+++
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStartEventHandler.java
@@ -71,7 +71,7 @@ public class WorkflowStartEventHandler implements
WorkflowEventHandler {
}
} else if (WorkflowSubmitStatue.FAILED ==
workflowSubmitStatue) {
logger.error(
- "Failed to submit the workflow instance, will
resend the workflow start event: {}",
+ "Failed to submit the workflow instance, will
resend the workflow start event: {}",
workflowEvent);
WorkflowStateEvent stateEvent =
WorkflowStateEvent.builder()
.processInstanceId(processInstance.getId())
