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 9c2838ccc9 fix the status of logical task is not be correctly changed 
when task is finished. (#14820) (#14822)
9c2838ccc9 is described below

commit 9c2838ccc9794fb2f292ed6cd240687f056cc519
Author: sgw <[email protected]>
AuthorDate: Sun Aug 27 13:20:37 2023 +0800

    fix the status of logical task is not be correctly changed when task is 
finished. (#14820) (#14822)
---
 .../runner/message/LogicTaskInstanceExecutionFinishEventSender.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/message/LogicTaskInstanceExecutionFinishEventSender.java
 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/message/LogicTaskInstanceExecutionFinishEventSender.java
index 94fc1f57ec..ad5ea37ec6 100644
--- 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/message/LogicTaskInstanceExecutionFinishEventSender.java
+++ 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/message/LogicTaskInstanceExecutionFinishEventSender.java
@@ -34,7 +34,7 @@ public class LogicTaskInstanceExecutionFinishEventSender
         ITaskInstanceExecutionEventListener 
iTaskInstanceExecutionEventListener =
                 SingletonJdkDynamicRpcClientProxyFactory.getInstance()
                         .getProxyClient(message.getHost(), 
ITaskInstanceExecutionEventListener.class);
-        iTaskInstanceExecutionEventListener.onTaskInstanceExecutionFinish(new 
TaskInstanceExecutionFinishEvent());
+        
iTaskInstanceExecutionEventListener.onTaskInstanceExecutionFinish(message);
     }
 
     @Override

Reply via email to