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);

Reply via email to