(dolphinscheduler) branch dev updated: Set TaskGroupQueue updateTime when force start (#15510)

[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 0dc373df2a Set TaskGroupQueue updateTime when force start (#15510)
0dc373df2a is described below

commit 0dc373df2a3238fa5d8eceb02dddb15a7b0e5b1d
Author: Wenjun Ruan <wen...@apache.org>
AuthorDate: Thu Jan 18 22:11:50 2024 +0800

    Set TaskGroupQueue updateTime when force start (#15510)
---
 .../apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java
 
b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java
index 6396f1dcb9..25eca41158 100644
--- 
a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java
+++ 
b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java
@@ -107,6 +107,7 @@ import java.time.ZonedDateTime;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
+import java.util.Date;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
@@ -678,6 +679,7 @@ public class ExecutorServiceImpl extends BaseServiceImpl 
implements ExecutorServ
         }
 
         taskGroupQueue.setForceStart(Flag.YES.getCode());
+        taskGroupQueue.setUpdateTime(new Date());
         processService.updateTaskGroupQueue(taskGroupQueue);
         log.info("Sending force start command to master: {}.", 
processInstance.getHost());
         ILogicTaskInstanceOperator iLogicTaskInstanceOperator = 
SingletonJdkDynamicRpcClientProxyFactory