Browse Source

fix the status of logical task is not be correctly changed when task is finished. (#14820) (#14822)

sgw 1 year ago
parent
commit
9c2838ccc9

+ 1 - 1
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