JinyLeeChina commented on issue #8828: URL: https://github.com/apache/dolphinscheduler/issues/8828#issuecomment-1092467321
Solution: 1. When master gets the worker load, it determines the number of worker's current tasks. 2. When worker gets a task, if the execution queue and waiting queue are already full, worker refuses to do so. Worker reject task implementation: 1. master maintains a sent queue. 2. worker, if there is no thread or busy, notifies master that it refuses to receive the task, and master sends the task of sending the queue to the queue to be sent. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
