(dolphinscheduler) branch dev updated: [Fix-17217] HotFix TaskKillLifecycleEvent/TaskPauseLifecycleEvent retry interval (#17218)

[wenjun]

This is an automated email from the ASF dual-hosted git repository.

wenjun pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new cdb60a3abd [Fix-17217] HotFix 
TaskKillLifecycleEvent/TaskPauseLifecycleEvent retry interval (#17218)
cdb60a3abd is described below

commit cdb60a3abd689d2c60c5ed53b8a97daaa7d75f77
Author: Wenjun Ruan <wen...@apache.org>
AuthorDate: Wed May 28 23:08:38 2025 +0800

    [Fix-17217] HotFix TaskKillLifecycleEvent/TaskPauseLifecycleEvent retry 
interval (#17218)
---
 .../master/engine/task/statemachine/TaskSubmittedStateAction.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/statemachine/TaskSubmittedStateAction.java
 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/statemachine/TaskSubmittedStateAction.java
index ba42fa6cc4..66df54d9d7 100644
--- 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/statemachine/TaskSubmittedStateAction.java
+++ 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/statemachine/TaskSubmittedStateAction.java
@@ -133,7 +133,7 @@ public class TaskSubmittedStateAction extends 
AbstractTaskStateAction {
         log.info("The task[id={}] is submitted and already dispatched, cannot 
pause, will try to pause it after 5s",
                 taskExecutionRunnable.getId());
         taskExecutionRunnable.getWorkflowEventBus()
-                .publish(TaskPauseLifecycleEvent.of(taskExecutionRunnable, 
TimeUnit.SECONDS.toSeconds(5)));
+                .publish(TaskPauseLifecycleEvent.of(taskExecutionRunnable, 
TimeUnit.SECONDS.toMillis(5)));
     }
 
     @Override
@@ -157,7 +157,7 @@ public class TaskSubmittedStateAction extends 
AbstractTaskStateAction {
         log.info("The task[id={}] is submitted and already dispatched, cannot 
kill, will kill it after 5s",
                 taskExecutionRunnable.getId());
         taskExecutionRunnable.getWorkflowEventBus()
-                .publish(TaskKillLifecycleEvent.of(taskExecutionRunnable, 
TimeUnit.SECONDS.toSeconds(5)));
+                .publish(TaskKillLifecycleEvent.of(taskExecutionRunnable, 
TimeUnit.SECONDS.toMillis(5)));
     }
 
     @Override