Dear Wiki user, You have subscribed to a wiki page or wiki category on "Hama Wiki" for change notification.
The "Scheduler" page has been changed by ChiaHungLin: https://wiki.apache.org/hama/Scheduler?action=diff&rev1=3&rev2=4 <<TableOfContents(5)>> - - == Responsibility == - - * Watch resched (queue?) for job-task event. - * Watch resched (queue?) for groom-offline event. - * Watch wait queue, move to processing one. - * Dispatch directive(s) == Procedure == + * Check taskAssignQueue if empty request Receptionist + * Receive a job from Receptionist - * schedule active tasks to GroomServer(s) + * schedule active tasks to particular GroomServer(s) + * Wait for GroomServer request, with GroomServerSpec, for task assign. - * Check received request, from a particular GroomServer's TaskManager, for task assignment. - * chec with criteria: - {{{ + {{{ - if active tasks scheduled to the same groom server + to be assigned task > GroomServerSpec.totalSlots + if active tasks scheduled to the same groom server + + to be assigned task > GroomServerSpec.totalSlots skip GroomServer's TaskManager request else dispatch directive(task) - }}} + }}} - + * Check if all tasks for a job is scheduled/ assigned + * if true, move the job to processingQueue else wait for GroomServer request. + * If RescheduledTask event triggered,
