You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@dolphinscheduler.apache.org by GitBox <gi...@apache.org> on 2022/04/08 05:55:26 UTC

[GitHub] [dolphinscheduler] JinyLeeChina commented on issue #8828: [Bug] [Master] Assign tasks to worker optimization

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: commits-unsubscribe@dolphinscheduler.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org