Job distributed within a grid environment using mega-host groupings of execution hosts based on resource attributes

Patent metadata

Field	Value
Publication number	US-9477529-B2
Application number	US-201213528571-A
Country	US
Kind code	B2
Filing date	Jun 20, 2012
Priority date	Jun 20, 2012
Publication date	Oct 25, 2016
Grant date	Oct 25, 2016

Abstract

According to one aspect of the present disclosure, a method and technique for job distribution within a grid environment is disclosed. The method includes: receiving jobs at a submission cluster for distribution of the jobs to at least one of a plurality of execution clusters, each execution cluster comprising one or more execution hosts; determining resource attributes corresponding to each execution host of the execution clusters; grouping, for each execution cluster, execution hosts based on the resource attributes of the respective execution hosts; defining, for each grouping of execution hosts, a mega-host for the respective execution cluster, the mega-host for a respective execution cluster defining resource attributes based on the resource attributes of the respective grouped execution hosts; determining resource requirements for the jobs; and identifying candidate mega-hosts for the jobs based on the resource attributes of the respective mega-hosts and the resource requirements of the jobs.

First claim

What is claimed is:

1. A method for job distribution within a grid environment, comprising:
receiving jobs at a submission cluster for distribution of the jobs to at least one of a plurality of execution clusters, each execution cluster comprising one or more execution hosts;
determining resource attributes corresponding to each execution host of the execution clusters;
grouping, for each execution cluster, execution hosts based on the resource attributes of the respective execution hosts;
defining, for each grouping of execution hosts, a mega-host for the respective execution cluster, the mega-host for a respective execution cluster defining resource attributes based on the resource attributes of the respective grouped execution hosts;
determining resource requirements for the jobs;
grouping the jobs based on the respective resource requirements of the jobs;
identifying candidate mega-hosts for each group of jobs based on the resource attributes of the respective mega-hosts and the resource requirements of the jobs; and
during a scheduling cycle, in response to determining that one job of a particular group of jobs cannot be forwarded to the execution clusters, ignoring remaining jobs in the particular group of jobs during the scheduling cycle.

2. The method of claim 1 , further comprising grouping the execution hosts for a respective execution cluster based on resource slots and memory capacity attributes for the respective execution hosts.

3. The method of claim 1 , further comprising sorting each group of jobs based on a user submitting the respective job.

4. The method of claim 1 , further comprising:
creating a plurality of priority queues based on priorities of the submitted jobs; and
assigning each group of jobs to a corresponding priority queue.

5. The method of claim 1 , further comprising:
creating a plurality of priority queues based on priorities of the submitted jobs;
sorting each group of jobs based on a user submitting the respective job; and
assigning each group of jobs submitted by a particular user to a corresponding priority queue.

6. A system for job distribution within a grid environment, comprising:
a submission cluster, having a processor, for distributing jobs to at least one of a plurality of execution clusters, wherein each execution cluster comprises one or more execution hosts, and wherein the submission cluster comprises logic executable by the processor to:
determine resource attributes corresponding to each execution host of the execution clusters;
group, for each execution cluster, execution hosts based on the resource attributes of the respective execution hosts;
define, for each grouping of execution hosts, a mega-host for the respective execution cluster, the mega-host for a respective execution cluster defining resource attributes based on the resource attributes of the respective grouped execution hosts;
determine resource requirements for the jobs; and
group the jobs based on the respective resource requirements of the jobs;
identify candidate mega-hosts for each group of jobs based on the resource attributes of the respective mega-hosts and the resource requirements of the jobs; and
during a scheduling cycle, in response to determining that one job of a particular group of jobs cannot be forwarded to the execution clusters, ignore remaining jobs in the particular group of jobs during the scheduling cycle.

7. The system of claim 6 , wherein the logic is executable to group the execution hosts for a respective execution cluster based on resource slots and memory capacity attributes for the respective execution hosts.

8. The system of claim 6 , wherein the logic is executable to sort each group of jobs based on a user submitting the respective job.

9. The system of claim 6 , wherein the logic is executable to:
create a plurality of priority queues based on priorities of the submitted jobs; and
assign each group of jobs to a corresponding priority queue.

10. The system of claim 6 , wherein the logic is executable to:
create a plurality of priority queues based on priorities of the submitted jobs;
sort each group of jobs based on a user submitting the respective job; and
assign each group of jobs submitted by a particular user to a corresponding priority queue.

11. A computer program product for job distribution within a grid environment, the computer program product comprising:
a non-transitory computer readable medium having computer readable program code embodied therewith, the computer readable program code comprising computer readable program code configured to:
determine resource attributes corresponding to each execution host of the execution clusters;
group, for each execution cluster, execution hosts based on the resource attributes of the respective execution hosts;
define, for each grouping of execution hosts, a mega-host for the respective execution cluster, the mega-host for a respective execution cluster defining resource attributes based on the resource attributes of the respective grouped execution hosts;
determine resource requirements for the jobs;
group the jobs based on the respective resource requirements of the jobs;
identify candidate mega-hosts for each group of jobs based on the resource attributes of the respective mega-hosts and the resource requirements of the jobs; and
during a scheduling cycle, in response to determining that one job of a particular group of jobs cannot be forwarded to the execution clusters, ignore remaining jobs in the particular group of jobs during the scheduling cycle.

12. The computer program product of claim 11 , wherein the computer readable program code is configured to group the execution hosts for a respective execution cluster based on resource slots and memory capacity attributes for the respective execution hosts.

13. The computer program product of claim 11 , wherein the computer readable program code is configured to:
create a plurality of priority queues based on priorities of the submitted jobs; and
assign each group of jobs to a corresponding priority queue.

14. The computer program product of claim 11 , wherein the computer readable program code is configured to:
create a plurality of priority queues based on priorities of the submitted jobs;
sort each group of jobs based on a user submitting the respective job; and
assign each group of jobs submitted by a particular user to a corresponding priority queue.

Assignees

• Chen Chong
• Liu Fang
• Wang Qi
• Yuan Shutao
• IBM

Inventors

• Chen Chong
• Liu Fang
• Wang Qi
• Yuan Shutao

Classifications

• G06F9/505

  considering the load · CPC title

• G06F9/4881 Primary

  Scheduling strategies for dispatcher, e.g. round robin, multi-level priority queues · CPC title

• G06F2209/5012

  Processor sets · CPC title

• G06F9/5044

  considering hardware capabilities · CPC title

• G06F2209/505

  Clust · CPC title