You can look at the official website:[1] It might be easier to understand.
If you encounter any problems, you can always email to chat. [1] https://dolphinscheduler.apache.org/en-us/docs/1.3.6/user_doc/quick-start.html Best Wishes！ CalvinKirs, Apache DolphinScheduler PMC On 08/2/2021 18:27，[email protected]<[email protected]> wrote： get it,thx. [email protected] From: Calvin Kirs Date: 2021-08-02 18:17 To: [email protected] Subject: Re:About the source code 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]
