MasterSchedulerService
online()
submitStandByTask()
buildFlowDag()
init()
new WorkflowExecuteThread
ServerNodeManager
create commond and store into db
TaskPriorityQueueImpl
findCommands()
线程池控制startProcess()
new NettyRemotingServer(serverConfig)
dispatchTask()
initTaskQueue()
DB
batchDispatch(fetchTaskNum)
dispatcher.dispatch(executionContext)
put()
failoverMasterWithLock(host)
Scheduler
updateMasterNodes()
installPlugin()
EventExecuteService
select DB
ProcessScheduleJob
xecutorManager.execute(context)
run()
command2ProcessInstance(commands)
handleEvents()
submitTask()
submitTaskExec(task)
Api
TaskPluginManager
addJob()
dispatchTask(taskPriority)
MasterServer
execute()
NettyExecutorManager
workflowExecuteThreadPool.startWorkflow(workflowExecuteThread)
NettyRemotingServer
poll()
Worker
t_ds_process_instance
workflowExecuteThreadPool.executeEvent(workflowExecuteThread)
get slot
updateProcessInstanceState()
TaskProcessorFactory.getTaskProcessor(taskInstance.getTaskType())taskProcessor.action(TaskAction.SUBMIT)
TaskProcessorFactoryServiceLoader.load(ITaskProcessor.class)
submitPostNode(null)
stateEvents.add(stateEvent)
TaskPriorityQueueConsumer
ExecutorDispatcher
start()
scheduleProcess()
WorkflowExecuteThread
FailoverExecuteThread
quartz_Commond
failoverService.checkMasterFailover()
MasterRegistryClient
CommonTaskProcessor
eventHandler()
load()
