AGGREGATING INFORMATION OF DISTRIBUTED JOBS

• US 20120254277A1
• Filed: 03/28/2011
• Published: 10/04/2012
• Est. Priority Date: 03/28/2011
• Status: Abandoned Application

• Current Assignee: Hewlett Packard Enterprise Development LP (Hewlett-Packard Enterprise Company)
• Original Assignee: Hewlett Packard Enterprise Development LP (Hewlett-Packard Enterprise Company)
• Inventors: Ho, Patty Peichen, Raghunathan, Balaji, Stepanenko, Anna
• Application Number:
  US13/073,028
• Publication Number:
  US 20120254277A1
• Time in Patent Office: Days
• US Class Current: 709/201
• CPC Class Codes: G06F 11/0715 in a system implementing multitasking multitasking per se G06F9/46
• CPC Class Codes: G06F 11/0766 Error or fault reporting or storing
• CPC Class Codes: G06F 11/3017 where the computing system is implementing multitasking multiprogramming arrangements G06F9/46; allocation of resources G06F9/50
• CPC Class Codes: G06F 11/302 where the computing system component is a software system
• CPC Class Codes: G06F 11/3055 Monitoring arrangements for monitoring the status of the computing system or of the computing system component, e.g. monitoring if the computing system is on, off, available, not available error or fault processing without redundancy G06F11/0703; error detection or correction by redundancy in data representation G06F11/08; error detection or correction by redundancy in operation G06F11/14; error detection or correction by redundancy in hardware G06F11/16
• CPC Class Codes: G06F 9/4843 by program, e.g. task dispatcher, supervisor, operating system

Abstract

Example embodiments disclosed herein relate to the aggregation of information included in messages associated with a distributed job. The messages are associated with a job identifier corresponding to the distributed job. The information can be aggregated based on the job identifier.

Claims

1. A method comprising:

determining a schedule for a distributed job for a plurality of devices;

transmitting the schedule to the devices;

receiving a plurality of messages associated with a job identifier corresponding to the distributed job processed at the devices, wherein the messages are respectively associated with the devices; and

aggregating information included in the messages based on the job identifier.

2. The method of claim 1, wherein the distributed job includes a plurality of job instances associated with the job identifier, and wherein the job instances are respectively associated with the devices.

3. The method of claim 2, further comprising:

determining an aggregated status based on the messages.

4. The method of claim 3, wherein the aggregated status indicates running if at least one of the job instances has not completed execution.

5. The method of claim 3, wherein the aggregated status indicates successful if each of the job instances has been completed and is determined to be successful.

6. The method of claim 3, wherein the aggregated status indicates an error of at least one job instance.

7. The method of claim 1, wherein the distributed job is described in a configuration file including a job type and result processing information.

8. The method of claim 7, wherein the result processing information includes directives to configure the respective messages, wherein the messages include a result identifier field and a data field.

9. The method of claim 8, further comprising:

determining to aggregate the information based on the directives;

determining an aggregated status, an aggregated result, or a combination thereof based on the messages; and

causing presentation of the aggregated status, the aggregated result, or a combination thereof.

10. A device comprising:

a scheduling module to determine a schedule for a distributed job associated with a set of devices;

a transmitter to transmit the schedule to the respective devices of the set;

a receiver to receives a plurality of messages,

wherein the messages are respectively associated with the devices of the set, and

wherein the messages are associated with a job identifier corresponding to the distributed job processed at the respective devices of the set; and

an aggregation manager module to aggregate information included in the messages based on the job identifier.

11. The device of claim 10, wherein the distributed job includes a plurality of job instances respectively associated with the devices, and wherein a trigger time is scheduled to trigger execution of the job instances on the respective devices.

12. The device of claim 11, wherein the job identifier is based on an identifier associated with the schedule and the trigger time.

13. A non-transitory machine-readable storage medium storing instructions that, if executed by a processor of a device, cause the processor to:

receive a plurality of messages from a plurality of devices,

wherein the messages are associated with a job identifier corresponding to a distributed job processed via a plurality of job instances respectively associated with the devices; and

aggregate information included in the messages based on the job identifier,

wherein the job identifier is based, at least in part, on a schedule associated with the distributed job.

14. The non-transitory machine-readable storage medium of claim 13, further comprising instructions that, if executed by the processor, cause the processor to:

determine an aggregated status based on the messages.

15. The non-transitory machine-readable storage medium of claim 13, further comprising instructions that, if executed by the processor, cause the processor to:

determine to aggregate the information included in the messages based on one or more directives;

determine an aggregated status, an aggregated result, or a combination thereof based on the messages; and

cause presentation of the aggregated status, the aggregated result, or a combination thereof.