This is an automated email from the ASF dual-hosted git repository. zhongjiajie pushed a commit to branch 3.2.1-prepare in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
commit 7d660ec2f93c69599ab9620c9456be597894f6dc Author: 小可耐 <46134044+sdh...@users.noreply.github.com> AuthorDate: Mon Feb 5 14:23:16 2024 +0800 [Bug][force-success] force success add end time (#15144) Co-authored-by: Rick Cheng <rickche...@gmail.com> (cherry picked from commit e5a208f363abcb31bb7e8ffee16c7a142671c667) --- .../dolphinscheduler/api/service/impl/TaskInstanceServiceImpl.java | 1 + 1 file changed, 1 insertion(+) diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/TaskInstanceServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/TaskInstanceServiceImpl.java index d3426dfa3e..f06f8115a9 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/TaskInstanceServiceImpl.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/TaskInstanceServiceImpl.java @@ -255,6 +255,7 @@ public class TaskInstanceServiceImpl extends BaseServiceImpl implements TaskInst // change the state of the task instance task.setState(TaskExecutionStatus.FORCED_SUCCESS); + task.setEndTime(new Date()); int changedNum = taskInstanceMapper.updateById(task); if (changedNum > 0) { processService.forceProcessInstanceSuccessByTaskInstanceId(taskInstanceId);