hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Apache Wiki <wikidi...@apache.org>
Subject [Hama Wiki] Trivial Update of "Scheduler" by ChiaHungLin
Date Tue, 29 Apr 2014 11:50:17 GMT
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, 
  

Mime
View raw message