You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ke...@apache.org on 2023/09/05 06:50:19 UTC

[dolphinscheduler] branch 3.1.9-prepare updated: Set task end time when subprocess notify by remote (#14856)

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

kerwin pushed a commit to branch 3.1.9-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/3.1.9-prepare by this push:
     new 6e99c6af18 Set task end time when subprocess notify by remote (#14856)
6e99c6af18 is described below

commit 6e99c6af1881152a84a1782b7a59ea1b350648dc
Author: 旺阳 <qi...@cisco.com>
AuthorDate: Tue Sep 5 14:50:14 2023 +0800

    Set task end time when subprocess notify by remote (#14856)
---
 .../dolphinscheduler/server/master/event/TaskStateEventHandler.java      | 1 +
 1 file changed, 1 insertion(+)

diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskStateEventHandler.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskStateEventHandler.java
index 5f88a1c1f9..84d099b297 100644
--- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskStateEventHandler.java
+++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskStateEventHandler.java
@@ -90,6 +90,7 @@ public class TaskStateEventHandler implements StateEventHandler {
             if (iTaskProcessor.taskInstance().getState().isFinished()) {
                 if (iTaskProcessor.taskInstance().getState() != task.getState()) {
                     task.setState(iTaskProcessor.taskInstance().getState());
+                    task.setEndTime(iTaskProcessor.taskInstance().getEndTime());
                 }
                 workflowExecuteRunnable.taskFinished(task);
             }