From 0dc373df2a3238fa5d8eceb02dddb15a7b0e5b1d Mon Sep 17 00:00:00 2001 From: Wenjun Ruan Date: Thu, 18 Jan 2024 22:11:50 +0800 Subject: [PATCH] Set TaskGroupQueue updateTime when force start (#15510) --- .../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