test/DolphinScheduler
1
0
Fork 0
mirror of https://gitee.com/dolphinscheduler/DolphinScheduler.git synced 2024-12-02 04:08:31 +08:00
Code Issues Actions 10 Packages Projects Releases Wiki Activity

Fix task instance will generate multiple times when retry interval is 0/s (#13571)

Browse Source
This commit is contained in:
Wenjun Ruan 2023-02-18 23:41:16 +08:00 committed by GitHub
parent dd4804ee4c
commit e8b20def54
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskStateEventHandler.java
View File

@ -57,10 +57,19 @@ public class TaskStateEventHandler implements StateEventHandler {
task.getState(), taskStateEvent.getStatus());
Map<Long, Integer> completeTaskMap = workflowExecuteRunnable.getCompleteTaskMap();
if (task.getState().isFinished()
&& (taskStateEvent.getStatus() != null && taskStateEvent.getStatus().isRunning())) {
String errorMessage = String.format(
"The current task instance state is %s, but the task state event status is %s, so the task state event will be ignored",
task.getState(),
taskStateEvent.getStatus());
log.warn(errorMessage);
throw new StateEventHandleError(errorMessage);
}
if (task.getState().isFinished()) {
if (completeTaskMap.containsKey(task.getTaskCode())
&& completeTaskMap.get(task.getTaskCode()) == task.getId()) {
&& completeTaskMap.get(task.getTaskCode()).equals(task.getId())) {
log.warn("The task instance is already complete, stateEvent: {}", stateEvent);
return true;
}