From 9c2838ccc9794fb2f292ed6cd240687f056cc519 Mon Sep 17 00:00:00 2001 From: sgw <2784266418@qq.com> Date: Sun, 27 Aug 2023 13:20:37 +0800 Subject: [PATCH] fix the status of logical task is not be correctly changed when task is finished. (#14820) (#14822) --- .../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