Browse Source

[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
2.0.7-release
OS 3 years ago committed by lenboo
parent
commit
652b9230a7
  1. 3
      dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/EventExecuteService.java

3
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( StateEventChangeCommand stateEventChangeCommand = new StateEventChangeCommand(
processInstanceId, 0, workflowExecuteThread.getProcessInstance().getState(), processInstance.getId(), taskInstance.getId() processInstanceId, 0, workflowExecuteThread.getProcessInstance().getState(), processInstance.getId(), taskInstance.getId()
); );
stateEventCallbackService.sendResult(address, port, stateEventChangeCommand.convert2Command()); stateEventCallbackService.sendResult(address, port, stateEventChangeCommand.convert2Command());
} }
@Override @Override
public void onFailure(Throwable throwable) { public void onFailure(Throwable throwable) {
logger.info("handle events {} failed.", processInstanceId);
logger.info("handle events failed.", throwable);
} }
}; };
Futures.addCallback(future, futureCallback, this.listeningExecutorService); Futures.addCallback(future, futureCallback, this.listeningExecutorService);

Loading…
Cancel
Save