Worker and Master communicate through Netty, and both queues are local queues. WorkerManagerThread gets TaskExecuteThread from workerExecuteQueue and executes it. TaskExecuteThread.run() performs AbstractTask.handle() processing, and after processing, calls NettyRemoteChannel in TaskCallbackService.sendResult() to send a responseCommand message to the master
Best Wishes！ CalvinKirs, Apache DolphinScheduler PMC On 08/2/2021 17:02，[email protected]<[email protected]> wrote： Hello everyone. After MasterBaseTaskExecThread submit task to db, the dispatch task will be carried out, but it will be put into the TaskPriorityQueue queue. But the WorkerManagerThread thread takes specific tasks from the workerExecuteQueue queue for execution. How are the two related? [email protected]
