Skip to content

Commit cdb60a3

Browse files
authored
[Fix-17217] HotFix TaskKillLifecycleEvent/TaskPauseLifecycleEvent retry interval (#17218)
1 parent fa8a431 commit cdb60a3

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/statemachine/TaskSubmittedStateAction.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,7 @@ public void pauseEventAction(final IWorkflowExecutionRunnable workflowExecutionR
133133
log.info("The task[id={}] is submitted and already dispatched, cannot pause, will try to pause it after 5s",
134134
taskExecutionRunnable.getId());
135135
taskExecutionRunnable.getWorkflowEventBus()
136-
.publish(TaskPauseLifecycleEvent.of(taskExecutionRunnable, TimeUnit.SECONDS.toSeconds(5)));
136+
.publish(TaskPauseLifecycleEvent.of(taskExecutionRunnable, TimeUnit.SECONDS.toMillis(5)));
137137
}
138138

139139
@Override
@@ -157,7 +157,7 @@ public void killEventAction(final IWorkflowExecutionRunnable workflowExecutionRu
157157
log.info("The task[id={}] is submitted and already dispatched, cannot kill, will kill it after 5s",
158158
taskExecutionRunnable.getId());
159159
taskExecutionRunnable.getWorkflowEventBus()
160-
.publish(TaskKillLifecycleEvent.of(taskExecutionRunnable, TimeUnit.SECONDS.toSeconds(5)));
160+
.publish(TaskKillLifecycleEvent.of(taskExecutionRunnable, TimeUnit.SECONDS.toMillis(5)));
161161
}
162162

163163
@Override

0 commit comments

Comments
 (0)