TaskExecuteProcessor
TaskCallbackService
1.send TASK_EXECUTE_RUNNING Command2. task handle3. send TASK_EXECUTE_RESPONSE Command
handle TASK_EXECUTE_RUNNING_ACKCommand
register TASK_KILL_RESPONSE
NettyClientHandler
NettyRemotingServer
NettyRemotingClient
NettyServerHandler
1. send TASK_EXEUTE_REQUEST COMMAND2. create TaskInstance3. create DISPATCH TaskEvent and update TaskInstance
handleTASK_EXECUTE_RESPONSECommand
TaskKillResponseProcessor
1. timeout or stop business2. send TASK_KILL_REQUEST Command
1. create RUNNINGTaskEvent 2. update TaskInstance3.send TASK_EXECUTE_RUNNING_ACK Commond
registerTASK_EXECUTE_RESPONSE_ACK
handleTASK_KILL_RESPONSECommand
TaskKillProcessor
handle TASK_EXECUTE_REQUESTCommand
registerTASK_EXECUTE_REQUESThandler
register TASK_EXECUTE_RUNNINGhandler
TaskPriorityQueueConsumer
1. kill process2. send TASK_KILL_RESPONSE Command
registerTASK_EXECUTE_RUNNING_ACK
TaskExecuteRunningProcessor
cached netty channel
1. create RESULT TaskEvent2. update TaskInstance3.send TASK_EXECUTE_RESPONSE_ACK Commond
WorkerServer
MasterServer
MasterSchedulerService
handle TASK_EXECUTE_RESPONSE_ACKCommand
TaskExecuteRunningAckProcessor
handle
handleTASK_EXECUTE_RUNNINGCommand
NettyExecutorManager
registerTASK_KILL_REQUESThandler
handle TASK_EXECUTE_REQUESTCommand
WorkerNettyProxyClient
MasterNettyProxyClient
register TASK_EXECUTE_RESPONSEhandler
TaskExecuteResponseAckProcessor
1. remove running cache2. remove cache channel
TaskExecuteResponseProcessor
cached netty channel
1. log kill response
1. remove running cache
