Computer-readable recording medium storing information processing program, information processing method, and information processing apparatus

Patent metadata

Field	Value
Publication number	US-12393445-B2
Application number	US-202318474378-A
Country	US
Kind code	B2
Filing date	Sep 26, 2023
Priority date	Dec 26, 2022
Publication date	Aug 19, 2025
Grant date	Aug 19, 2025

Abstract

A recording medium stores a program causing a computer to execute a process including: classifying, based on a processing content of each job in a job group which has an execution order defined in a job flow, the job group into a groups; and restarting, when an abnormality of a first job classified into a first group of the groups is detected, by referring to a memory that stores information which indicates a job in a head execution order in a group as a starting point from which the job flow is to be restarted, based on information which indicates a job in a head execution order in a second group as a starting point from which the job flow is to be restarted, and is associated with the first group, the job flow from the job in the head execution order in the second group as the starting point.

First claim

What is claimed is:

1. A non-transitory computer-readable recording medium storing an information processing program causing a computer to execute a process comprising:
assigning an attribute including a collection, a processing, an integration and an accumulation to each of jobs in a job group which has an execution order defined in a job flow, based on a processing content of each of the jobs;
classifying, based on the attribute of each of the jobs, the jobs into a plurality of groups; and
restarting, in a case where an abnormality of a first job classified into a first group of the plurality of groups is detected, by referring to a memory that stores, in association with at least one group of the plurality of groups, information which indicates a job in a head execution order in a group as a starting point from which the job flow is to be restarted among the plurality of groups, based on information which indicates a job in a head execution order in a second group as a starting point from which the job flow is to be restarted, and is associated with the first group, the job flow from the job in the head execution order in the second group as the starting point,
wherein the information processing program causes the computer to execute a process of
adding, in response to reception of a request to add a third job which precedes a second job classified into the second group of the plurality of groups to the job group, the third job to the job group;
classifying the third job into a third group of the plurality of groups based on a processing content of the third job; and
updating, in a case where the third job is a job in a head execution order in the third group, information which indicates the job in the head execution order in the third group, and is stored in the memory,

wherein the plurality of groups include a collection group including one or more jobs with the attribute of the collection and into which a collection job for collecting data from a data source is classified, and in the classifying, in a case where it is determined that a fifth job included in the job group is the collection job based on a processing content of the fifth job, the fifth job is classified into the collection group,
wherein the plurality of groups include a processing group including one or more jobs with the attribute of the processing into which a processing job for acquiring and processing data which indicates a processing result from a single job is classified and in the classifying, in a case where it is determined that a sixth job included in the job group is the processing job based on a processing content of the sixth job, the sixth job is classified into the processing group,
wherein the plurality of groups include an integration group including one or more jobs with the attribute of the integration into which an integration job for acquiring and integrating data which indicates processing results from a plurality of jobs is classified, and in the classifying, in a case where it is determined that a seventh job included in the job group is the integration job based on a processing content of the seventh job, the seventh job is classified into the integration group,
wherein the plurality of groups include an accumulation group including one or more jobs with the attribute of the accumulation into which an accumulation job for acquiring data and storing the data in a database is classified, and in the classifying, in a case where it is determined that an eighth job included in the job group is the accumulation job based on a processing content of the eighth job, the eighth job is classified into the accumulation group.

2. The non-transitory computer-readable recording medium according to claim 1 , wherein the information processing program causes the computer to execute a process of
deleting, in response to reception of a request to delete a fourth job classified into a fourth group of the plurality of groups from the job group, the fourth job from the job group; and
updating, in a case where the fourth job is a job in a head execution order in the fourth group, information which indicates the job in the head execution order in the fourth group, and is stored in the memory.

3. The non-transitory computer-readable recording medium according to claim 1 , wherein
the memory stores, in association with at least one group of the plurality of groups, a condition for restarting the job flow and the information which indicates the job in the head execution order in the group as the starting point from which the job flow is to be restarted, among the plurality of groups,
the information processing program causing the computer to execute the process further comprises:
determining whether or not the detected abnormality of the first job satisfies a condition for restarting the job flow, which is associated with the first group, and
in the restarting, in a case where it is determined that the detected abnormality of the first job satisfies the condition for restarting the job flow, which is associated with the first group, by referring to the memory, based on the information which indicates the job in the head execution order in the second group as the starting point from which the job flow is to be restarted, and is associated with the first group, the job flow is restarted from the job in the head execution order in the second group as the starting point.

4. An information processing method comprising:
assigning an attribute including a collection, a processing, an integration and an accumulation to each of jobs in a job group which has an execution order defined in a job flow, based on a processing content of each of the jobs;
classifying, based on the attribute of each of the jobs, the jobs into a plurality of groups; and
restarting, in a case where an abnormality of a first job classified into a first group of the plurality of groups is detected, by referring to a memory that stores, in association with at least one group of the plurality of groups, information which indicates a job in a head execution order in a group as a starting point from which the job flow is to be restarted among the plurality of groups, based on information which indicates a job in a head execution order in a second group as a starting point from which the job flow is to be restarted, and is associated with the first group, the job flow from the job in the head execution order in the second group as the starting point,
wherein the information processing method further includes:
adding, in response to reception of a request to add a third job which precedes a second job classified into the second group of the plurality of groups to the job group, the third job to the job group;
classifying the third job into a third group of the plurality of groups based on a processing content of the third job; and
updating, in a case where the third job is a job in a head execution order in the third group, information which indicates the job in the head execution order in the third group, and is stored in the memory,

wherein the plurality of groups include a collection group including one or more jobs with the attribute of the collection and into which a collection job for collecting data from a data source is classified, and in the classifying, in a case where it is determined that a fifth job included in the job group is the collection job based on a processing content of the fifth job, the fifth job is classified into the collection group,
wherein the plurality of groups include a processing group including one or more jobs with the attribute of the processing into which a processing job for acquiring and processing data which indicates a processing result from a single job is classified, and in the classifying, in a case where it is determined that a sixth job included i

Assignees

• Fujitsu Ltd

Inventors

• Yoshikawa Daiki
• Kitayama Toru
• Hara Yusuke
• Shimogawa Kenichirou

Classifications

• G06F9/485 Primary

  Task life-cycle, e.g. stopping, restarting, resuming execution (G06F9/4881 takes precedence) · CPC title

• G06F9/4881 Primary

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