baiyibo commented on issue #4249:
URL:
https://github.com/apache/incubator-dolphinscheduler/issues/4249#issuecomment-760045262
`try{
...
}catch (Exception e) {
logger.error("task scheduler failure", e);
kill();// some exception will go to kill
**responseCommand.setStatus(ExecutionStatus.FAILURE.getCode());**
responseCommand.setEndTime(new Date());
responseCommand.setProcessId(task.getProcessId());
responseCommand.setAppIds(task.getAppIds());
} finally {
taskExecutionContextCacheManager.removeByTaskInstanceId(taskExecutionContext.getTaskInstanceId());
ResponceCache.get().cache(taskExecutionContext.getTaskInstanceId(),responseCommand.convert2Command(),Event.RESULT);
taskCallbackService.sendResult(taskExecutionContext.getTaskInstanceId(),
responseCommand.convert2Command());
}`
1.responseCommand.setStatus(ExecutionStatus.FAILURE.getCode());
This sentence has changed the status to failure
2.taskCallbackService.sendResult(taskExecutionContext.getTaskInstanceId(),
responseCommand.convert2Command());
Reponse to master
3.in class TaskResponseProcessor
taskResponseService.addResponse(taskResponseEvent);
4.TaskResponseService.TaskResponseWorker.run() ->
processService.changeTaskState
The status of the task instance is changed to failed
5.org.apache.dolphinscheduler.server.master.runner.MasterTaskExecThread#waitTaskQuit
taskInstance.getState().typeIsFinished() contain The name is failed state
so,break,waitTaskQuit->return ，There will be no obstruction
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
