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