This explanation also solved the trouble confusing me quite a while! Thanks!
=================== Stay Hungry, Stay Foolish Martin Huang [email protected] Sent with a Spark =================== 在 2021年8月2日 +0800 PM6:17，Calvin Kirs <[email protected]>，写道： > 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]
