First of all, thank you for your reply. But I still have some questions: 1. Does dispatchTask finally call MasterBaseTaskExecThread.dispatchTask or TaskPriorityQueueConsumer.dispatch? 2. When did the TaskComsumer (TaskPriorityQueueConsumer) in the picture start? Could not find its related code.
Best Wishes！ [email protected] From: CalvinKirs Date: 2021-08-02 18:32 To: [email protected] Subject: Re: About the source code 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]
