System and method for providing intelligent pre-staging of data in a compute environment

• US 8,763,000 B2
• Filed: 12/29/2008
• Issued: 06/24/2014
• Est. Priority Date: 03/13/2004
• Status: Active Grant

• Current Assignee: III Holdings 12, LLC (Intellectual Ventures LLC)
• Original Assignee: Adaptive Computing Enterprises, Inc. (Ala Services LLC)
• Inventors: Jackson, David Brian
• Primary Examiner(s): An, Meng
• Assistant Examiner(s): LEE, TAMMY EUNHYE
• Application Number:
  US12/344,844
• Publication Number:
  US 20090144215A1
• Time in Patent Office: 2,003 Days
• Field of Search: 718/102
• US Class Current: 718/104
• CPC Class Codes: G06F 15/161 Computing infrastructure, e.g. computer clusters, blade chassis or hardware partitioning casings, cabinets, racks or drawers for data centers H05K5/00
• CPC Class Codes: G06F 2209/5014 Reservation
• CPC Class Codes: G06F 2209/5015 Service provider selection
• CPC Class Codes: G06F 2209/5022 Workload threshold
• CPC Class Codes: G06F 2209/503 Resource availability
• CPC Class Codes: G06F 2209/506 Constraint
• CPC Class Codes: G06F 2209/508 Monitor
• CPC Class Codes: G06F 9/4881 Scheduling strategies for dispatcher, e.g. round robin, multi-level priority queues
• CPC Class Codes: G06F 9/5011 the resources being hardware resources other than CPUs, Servers and Terminals
• CPC Class Codes: G06F 9/5027 the resource being a machine, e.g. CPUs, Servers, Terminals
• CPC Class Codes: G06F 9/505 considering the load
• CPC Class Codes: G06F 9/5072 Grid computing

Abstract

A system, computer-readable medium and method for performing intelligent data pre-staging for a job submitted to a cluster environment. The method aspect comprises determining availability of compute resources including availability timeframes to process the submitted job, determining data requirements for processing the job and determining a co-allocation in time reservation.

Claims

1. A method comprising:

determining availability of compute resources in a compute environment including availability timeframes to process a workload submitted to the compute environment to yield a determined availability;

determining data requirements for processing the workload, the data requirements being associated with data to be retrieved from a storage medium for use by the workload, to yield determined data requirements;

based on the determined availability and the determined data requirements, establishing a data stage-in reservation associated with the data requirements for the workload to process that starts at a first start time, the data stage-in reservation only reserving resources associated with retrieving the data from the storage medium for use by the workload, wherein establishing the data stage-in reservation is based at least in part on (1) creating an availability range list from a calculation of existing resource guarantees and reservations and (2) converting the availability range list into a start range list;

performing data pre-staging according to the data stage-in reservation at the first start time; and

after performing the data pre-staging, processing the workload using the data and according to a compute reservation that starts at a second start time, which is later than the first start time.

2. The method of claim 1, wherein establishing the data stage-in reservation further comprises:

(1) requesting resources for a first step in the workload based on at least one of the determined availability and the determined data requirements;

(2) requesting another resource for a next step in a workload process and returning to step (1) until all resources for all steps in the workload are requested;

(3) shifting start ranges in the start range list by an offset and performing an intersection operation on a combination start range;

(4) shifting the start ranges back by a negative of the offset, wherein resulting information provides when to start each potential data stage-in reservation; and

(5) establishing the data stage-in reservation based on the resulting information that processes when to start each potential data stage-in reservation.

3. The method of claim 2, further comprising:

(1) presenting to a user a final list of selectable starting times for a data stage-in reservation; and

(2) upon receiving a user selection of a data stage-in reservation start time, establishing the data stage-in reservation.

4. The method of claim 1, wherein compute resources are available prior to completion of data stage-in.

5. The method of claim 1, wherein establishing the data stage-in reservation is based at least in part on an analysis of whether each step in the workload can be processed based on existing resource guarantees and reservations.

16. The method of claim 1, wherein establishing the data stage-in reservation is based on at least one of:

a network speed, a delivered bandwidth, data cache usage, disk usage, storage capacity, virtual hosting center resources and a duration of network bandwidth resources.

6. A system comprising:

a processor; and

a computer-readable medium storing instructions, which when executed by the processor, cause the processor to perform operations comprising;

determining data requirements for processing a workload, the data requirements being associated with data to be retrieved from a storage medium for use by the workload, to yield determined data requirements;

based on the determined availability and the determined data requirements, establishing a data stage-in reservation associated with the data requirements for the workload to process that starts at a first start time, the data stage-in reservation only reserving resources associated with retrieving the data from the storage medium for use by the workload, establishing the data stage-in reservation based at least in part on (1) creating an availability range list from a calculation of existing resource guarantees and reservations and (2) converting the availability range list into a start range list;

performing data pre-staging according to the data stage-in reservation at the first start time; and

after performing the data pre-staging, processing the workload using the data and according to a compute reservation that starts at a second start time, which is later than the first start time.

7. The system of claim 6, wherein the instructions, which, when executed on the processor, further perform operations comprising:

establishing the data stage-in reservation by;

(1) requesting resources for a first step in the workload based on at least one of the determined availability and the determined data requirements;

(2) requesting another resource for a next step in a workload process and returning to step (1) until all resources for all steps in the workload are requested;

(3) shifting start ranges in the start range list by an offset and performing an intersection operation on a combination start range;

(4) shifting the start ranges back by a negative of the offset, wherein resulting information provides when to start each potential data stage-in reservation; and

(5) establishing the data stage-in reservation based on the resulting information that processes when to start each potential data stage-in reservation.

8. The system of claim 7, wherein the instructions, which, when executed on the processor, further perform operations comprising:

presenting to a user a final list of selectable starting times for a data stage-in reservation and, upon receiving a user selection of a data stage-in reservation start time, establishing the data stage-in reservation.

9. The system of claim 6, wherein compute resources are available prior to completion of data stage-in.

10. The system of claim 6, wherein the instructions, which, when executed on the processor, further perform operations comprising:

establishing the data stage in reservation based on at least in part an analysis of whether each step in the workload can be processed based on existing resource guarantees and reservations.

11. A non-transitory computer-readable medium storing instructions for controlling a computing device, which, when executed on the computing device, perform operations comprising:

determining data requirements for processing a workload, the data requirements being associated with data to be retrieved from a storage medium for use by the workload, to yield determined data requirements;

based on the determined availability and the determined data requirements, establishing a data stage-in reservation associated with the data requirements for the workload to process that starts at a first start time, the data stage-in reservation only reserving resources associated with retrieving the data from the storage medium for use by the workload, wherein establishing the data stage-in reservation is based at least in part on (1) creating an availability range list from a calculation of existing resource guarantees and reservations and (2) converting the availability range list into a start range list;

performing data pre-staging according to the data stage-in reservation at the first start time; and

after performing the data pre-staging, processing the workload using the data and according to a compute reservation that starts at a second start time, which is later than the first start time.

12. The non-transitory computer-readable medium of claim 11, wherein establishing the data stage-in reservation, further comprises:

(1) requesting resources for a first step in the workload based on at least one of the determined availability and the determined data requirements;

(2) requesting another resource for a next step in a workload process and returning to step (1) until all resources for all steps in the workload are requested;

(3) shifting start ranges in the start range list by an offset and performing an intersection operation on a combination start range;

(4) shifting the start ranges back by a negative of the offset, wherein resulting information provides when to start each potential data stage-in reservation; and

(5) establishing the data stage-in reservation based on the resulting information that processes when to start each potential data stage-in reservation.

13. The non-transitory computer-readable medium of claim 12, the instructions further comprising:

(1) presenting to a user a final list of selectable starting times for the data stage-in reservation; and

(2) upon receiving a user selection of a data stage-in reservation start time, establishing the data stage-in reservation.

14. The non-transitory computer-readable medium of claim 11, wherein compute resources are available prior to completion of data stage-in.

15. The non-transitory computer-readable medium of claim 11, wherein establishing the data stage-in reservation is based at least in part on an analysis of whether each step in the workload can be processed based on existing resource guarantees and reservations.