This is an automated email from the ASF dual-hosted git repository. leonbao pushed a commit to branch 2.0.0-release in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
commit 652b9230a726939144abc5278d9e5b0d8659cd22 Author: OS <[email protected]> AuthorDate: Wed Nov 17 17:39:22 2021 +0800 [BUG][Master] process cannot finish and its status is always running (#6886) * fix 6882: process cannot finish and its status is always running * fix 6882: process cannot finish and its status is always running --- .../dolphinscheduler/server/master/runner/EventExecuteService.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/EventExecuteService.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/EventExecuteService.java index eae5353..4184ba0 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/EventExecuteService.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/EventExecuteService.java @@ -187,12 +187,13 @@ public class EventExecuteService extends Thread { StateEventChangeCommand stateEventChangeCommand = new StateEventChangeCommand( processInstanceId, 0, workflowExecuteThread.getProcessInstance().getState(), processInstance.getId(), taskInstance.getId() ); - stateEventCallbackService.sendResult(address, port, stateEventChangeCommand.convert2Command()); } @Override public void onFailure(Throwable throwable) { + logger.info("handle events {} failed.", processInstanceId); + logger.info("handle events failed.", throwable); } }; Futures.addCallback(future, futureCallback, this.listeningExecutorService);
