Job management system that determines if master data has been updated, then re-executes a sub-job based on available executing computers and data sharing status

• US 9,183,038 B2
• Filed: 11/10/2010
• Issued: 11/10/2015
• Est. Priority Date: 11/10/2010
• Status: Expired due to Fees

• Current Assignee: Hitachi, Ltd.
• Original Assignee: Hitachi, Ltd.
• Inventors: Hatabe, Norichika, Sugita, Tsutomu
• Primary Examiner(s): An, Meng
• Assistant Examiner(s): Chu Joy, Jorge A
• Application Number:
  US13/825,422
• Publication Number:
  US 20130219406A1
• Time in Patent Office: 1,826 Days
• Field of Search: None
• US Class Current: 1/1
• CPC Class Codes: G06F 2209/484 Precedence
• CPC Class Codes: G06F 2209/5017 Task decomposition
• CPC Class Codes: G06F 9/46 Multiprogramming arrangements
• CPC Class Codes: G06F 9/4881 Scheduling strategies for dispatcher, e.g. round robin, multi-level priority queues
• CPC Class Codes: G06F 9/5038 considering the execution order of a plurality of tasks, e.g. taking priority or time dependency constraints into consideration scheduling strategies G06F9/4881 and subgroups

Abstract

In a computer system of the present invention, whether or not master data has been updated is managed for each division key as master data management information. If the master data has been updated, a job is re-executed, but when the job is re-executed, data is divided using only a division key corresponding to updated master data, and thereby a sub-job which is a re-execution target is localized with the division key unit so as to re-execute a job.

Claims

1. A computer system comprising:

a plurality of job execution computers that execute a job net as a series of one or more jobs;

a management computer that generates a plurality of divided data items by dividing master data using one or more division keys indicating units for dividing the master data, and sets the job execution computers to process each of the plurality of divided data items so as to execute the jobs as one or more sub-jobs; and

at least one storage device that stores at least the master data and execution results of the one or more sub-jobs,

wherein the management computer manages, determines and updates update related information regarding whether or not the master data has been updated, where the update related information includes a file attribute which indicates that the master data has been changed and a file size of the master data, and manages updated division key information which is one of the division keys corresponding to an updated portion of the master data,

vacancies information indicating whether or not there is a capacity for executing one or more of the sub-jobs in each of the plurality of job execution computers, and

output file sharing information indicating whether or not execution results of the one or more sub-jobs are shared between the plurality of job execution computers, and

wherein the management computer is configured to;

when receiving a re-execution request, specify one of the divided data items corresponding to the updated division key information from the plurality of divided data items and which is updated after or during the execution of the one or more sub-jobs,

specify one of the sub-jobs corresponding to the specified divided data item,

when the vacancies information of a first one of the job execution computers which executed a preceding one of the sub-jobs to the specified one of the sub-jobs indicates that there is insufficient capacity for executing the specified one of the sub-jobs as a following sub-job, refer to the output file sharing information, and

set a second one of the job execution computers to execute the following sub-job based on whether the execution result of the preceding one of the sub-jobs is shared with the job execution computers.

2. The computer system according to claim 1,

wherein, when the vacancies information of the first one of the job execution computers which executed the preceding sub-job to the specified one of the sub-jobs indicates that there is capacity for executing the specified one of the sub-jobs, the first one of the job execution computers is set to execute the specified one of the sub-jobs.

3. The computer system according to claim 1,

wherein, when the execution result of the preceding sub-job cannot be used by the second one of the job execution computers, the management computer delays the setting of the second one of the job execution computers until the first one of the job execution computers which has executed the preceding sub-job has the capacity to execute the specified one of the sub-jobs.

4. The computer system according to claim 1,

wherein the management computer determines whether or not the master data has been updated using the file attribute.

5. The computer system according to claim 1,

wherein the update related information is update history information indicating a history in which the master data has been changed, and

wherein the management computer determines whether or not the master data has been updated using the update history information.

6. The computer system according to claim 1,

wherein the update related information is user action information indicating whether or not a master data editing button provided in a master data display screen for displaying content of the master data has been pressed, and

wherein the management computer determines that the master data has been updated when there is the user action information.

7. The computer system according to claim 1,

wherein the management computer displays management information of the master data and an execution result of the one or more sub-jobs on a display screen of a display device after the one or more sub-jobs are executed.

8. The computer system according to claim 7,

wherein the management computer displays the management information of the master data and the execution result of the one or more sub-jobs on the display screen of the display device in response to a request from a user.

9. The computer system according to claim 7,

wherein, in response to an instruction from a user, the management computer displays an editing screen for editing the master data on the display screen, receives an update of the master data, and reflects whether or not the update has been performed on the management information of the master data.

15. The computer system according to claim 1,

wherein the management computer sets the second one of the job execution computers to execute the following sub-job based on whether the execution result of the preceding one of the sub-jobs is shared with the job execution computers and whether the vacancies information of the job execution computers other than the first one indicates there is the capacity to execute the following sub-job in at least one of the job execution computers other than the first one.

16. The computer system according to claim 1,

wherein the output file sharing information indicating whether or not each of the execution results of the one or more sub-jobs is shared between the plurality of job execution computers.

17. The computer system according to claim 1,

wherein the output file sharing information indicates which of the execution results are accessible on the at least one storage device to each of the job execution computers.

10. A job execution management method in a computer system including a plurality of job execution computers executing a job net as a series of one or more jobs, and a management computer, the job execution management method performed by the management computer comprising:

generating a plurality of divided data items by dividing master data using one or more division keys indicating units for dividing the master data;

setting the job execution computers to process each of the plurality of divided data items so as to execute the jobs as one or more sub-jobs;

managing, determining and updating update related information regarding whether or not a master data has been updated, where the update related information includes a file attribute which indicates that the master data has been changed and a file size of the master data, and updated division key information which is one of the division keys corresponding to an updated portion of the master data;

managing vacancies information indicating whether or not there is a capacity for executing one or more of the sub-jobs in each of the plurality of job execution computers;

managing output file sharing information indicating whether or not execution results of the one or more sub-jobs are shared between the plurality of job execution computers;

when receiving a re-execution request, specifying one of the divided data items corresponding to the updated division key information from the plurality of divided data items and which is updated after or during the execution of the one or more sub-jobs;

specifying one of the sub-jobs corresponding to the specified divided data item;

when the vacancies information of a first one of the job execution computers which executed a preceding one of the sub-jobs to the specified one of the sub-jobs indicates that there is insufficient capacity for executing the specified one of the sub-jobs as a following sub-job, referring to the output file sharing information; and

setting a second one of the job execution computers to execute the following sub-job based on whether the execution result of the preceding one of the sub-jobs is shared with the job execution computers.

11. The job execution management method according to claim 10, further comprising:

displaying management information of the master data and an execution result of the one or more sub-jobs on a display screen of a display device after the one or more sub-jobs are executed.

12. The job execution management method according to claim 11, further comprising:

displaying, in response to an instruction from a user, an editing screen for editing the master data on the display screen;

receiving an update of the master data; and

reflecting whether or not the update has been performed on the management information of the master data.

13. The job execution management method according to claim 10,

wherein, when the vacancies information of the first one of the job execution computers which executed the preceding sub-job to the specified one of the sub-jobs indicates that there is capacity for executing the specified one of the sub-jobs, setting the first one of the job execution computers to execute the specified one of the sub-jobs.

14. A non-transitory computer-readable medium having instructions stored thereon that, when executed by a management computer, cause the management computer to perform a job execution management method in a computer system including a plurality of job execution computers executing a job net as a series of one or more jobs, the job execution management method performed by the management computer comprising:

generating a plurality of divided data items by dividing master data using one or more division keys indicating units for dividing the master data;

setting the job execution computers to process each of the plurality of divided data items so as to execute the jobs as one or more sub-jobs;

managing, determining and updating update related information regarding whether or not a master data has been updated, where the update related information includes a file attribute which indicates that the master data has been changed and a file size of the master data, and updated division key information which is one of the division keys corresponding to an updated portion of the master data;

managing vacancies information indicating whether or not there is a capacity for executing one or more of the sub-jobs in each of the plurality of job execution computers;

managing output file sharing information indicating whether or not execution results of the one or more sub-jobs are shared between the plurality of job execution computers;

when receiving a re-execution request, specifying one of the divided data items corresponding to the updated division key information from the plurality of divided data items and which is updated after or during the execution of the one or more sub-jobs;

specifying one of the sub-jobs corresponding to the specified divided data item;

when the vacancies information of a first one of the job execution computers which executed a preceding one of the sub-jobs to the specified one of the sub-jobs indicates that there is insufficient capacity for executing the specified one of the sub-jobs as a following sub-job, referring to the output file sharing information; and

setting a second one of the job execution computers to execute the following sub-job based on whether the execution result of the preceding one of the sub-jobs is shared with the job execution computers.