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