DolphinScheduler-work代码时序图
2024-11-11 17:58:23 0 举报DolphinScheduler-work代码时序图
作者其他创作
大纲/内容
sendTaskExecuteResponseCommand(taskExecutionContext)
workerRegistryClient.registry()
run()
taskPluginManager.getTaskChannelMap().get(taskExecutionContext.getTaskType())
sendTaskExecuteRunningCommand(taskExecutionContext)
retryReportTaskStatusThread.start()
Netty client
TaskCallbackService
SqlTask
workerManagerThread.start()
taskPluginManager.installPlugin()
workerManager.offer(TaskExecuteThread taskExecuteThread)
task.init()
WorkerManagerThread
new TaskExecuteThread
Masterserver
RetryReportTaskStatusThread
WorkerServer
TaskExecuteThread
TaskPluginManager
new NettyRemotingServer(serverConfig)
task.handle()
NettyRemotingServer
WorkerRegistryClient
TaskExecuteProcessor
start()
0 条评论
下一页
