JPH0883256A - Inquiry device for execution state of job on decentralized processing system - Google Patents

Abstract

PURPOSE: To provide an execution state inquiry device for the jog on the decentralized processing system which can grasp the execution state of jobs on the decentralized processing system in a short time. CONSTITUTION: Plural computer systems 2, 3, 4, 5, 6, and 7 which are connected through a communication medium 1 are provided with inquiry parts 8 and inquiry result generation parts 9 respectively. In each inquiry part 8, an inquiry transmission part 8a and an inquiry reception part 8b are constituted and in each inquiry result generation part 9, a history information storage part 9a and a history information analysis part 9b are constituted. The inquiry transmission part 8a inquires the execution states of the jobs of all computer systems that are put in charge of the jobs at a time. The inquiry reception part 8b receives history information from the respective computer systems in optional order. The history information storage part 9a stores the execution states of the jobs on the respective computers and the history information. The history information analysis part 9b arrays the history information received by the inquiry reception part 8b, in the execution order of the jobs.

Description

Detailed Description of the Invention

[0001]

BACKGROUND OF THE INVENTION 1. Field of the Invention The present invention relates to an apparatus for inquiring a job in order to know the execution status of the job being processed in each computer system of the distributed processing system.

[0002]

2. Description of the Related Art When performing a single work,
In many cases, it is efficient to divide the work into a plurality and share the work with a large number of people. The same applies to the case of processing a business by a computer system, and a distributed processing system has been developed in which data to be processed is divided into a plurality of jobs (jobs) and the plurality of computer systems share and process the jobs.

Such a distributed processing system is constructed on a network in which computer systems are connected by communication lines. Then, a user who uses the distributed processing system may need to know the execution state of the job that each computer system is in charge of.
Therefore, a normal distributed processing system is provided with a job execution status inquiry device. This execution status inquiring device inquires the execution status of a job from each computer system, and an inquiry unit that obtains an answer and an inquiry result that creates an inquiry result that is data related to the execution status of the entire business based on the answers from each computer system. It is composed of a creation unit. Then, the inquiry by the inquiry unit is sent from the computer system at the head of the job.
Track each computer system according to the order in which jobs are executed.

For example, it is assumed that a distributed processing system is composed of computer systems a, b, and c on a certain network, and the work to be processed by this distributed processing system consists of three jobs A, B, and C. It is assumed that job A is executed after job A is completed and job C is executed after job B is completed. Job A is computer system a, job B is computer system b, and job C is computer system c. Are assumed to be in charge of each. In this case, a user who wants to inquire about the execution state of a job first inquires the execution state of job A to the computer system a by the inquiry unit, confirms the answer from the computer system a, and then Job B for system b
Inquires about the execution status of. After confirming the answer from the computer system b, the computer system c
The execution status of job C is inquired. Further, after confirming the answer from the computer system c, the inquiry result creating unit creates an inquiry result based on the answers from the computer systems a, b and c.

As such an execution status inquiry device, a device disclosed in Japanese Patent Laid-Open No. 5-113963 has been proposed. This is a device for displaying the inquiry result of a job on the display of the terminal, etc., but in this device as well, in order to know the execution status of all the jobs belonging to one job, Inquiries are made individually for each computer system. And
Inquiry results are also displayed separately for each job.

[0006]

However, the job execution status inquiry device in the above distributed processing system has the following problems. That is,
Inquiries to each computer system are traced in the order in which jobs are executed. Therefore, the user who inquires the jobs needs to know in advance the order in which the jobs will be executed. In particular, when a computer system requests a part of a job to be executed by another computer system as a sub-job, the person who inquires the job can ask about which computer system the sub-job is requested for. It is inconvenient to know. Further, since the inquiries are made in the order in which the jobs are executed, the next inquiry cannot be made until the answer to the inquiry is returned. Therefore, it takes time to get an answer.

Further, since inquiries are sequentially made to each computer system, especially when a situation occurs in which an answer cannot be returned due to a failure in the computer system on the way, the job tracking is performed at that stage. Is interrupted. Therefore, in such a case, the execution status of the job cannot be grasped.

Further, in the invention of Japanese Patent Laid-Open No. 5-113963, inquiries are individually made for each computer system according to the order of executing jobs, and the display of inquiry results is also made separately for each job. It was difficult to understand the execution status of the entire work. In order to deal with this, it is conceivable that the jobs are arranged and displayed in the order of execution, but in this case as well, the user must know in advance the order in which the jobs will be executed.

The present invention has been proposed in order to solve the above-mentioned problems of the prior art, and its main purpose is to provide each of the jobs even if the user does not know the order of executing the jobs in advance. To provide a job execution status inquiry device in a distributed processing system capable of making an inquiry to a computer system in a short time.

A second purpose is to execute a job in a distributed processing system in which even if a reply cannot be obtained from a part of a plurality of computer systems that share a job, the reply from other computer systems is not hindered. It is to provide an inquiry device.

A third object is to provide a job execution status inquiry device in a distributed processing system capable of creating an inquiry result in which the execution status of the entire job can be easily understood even if the user does not know the order of executing jobs in advance. Is to provide.

[0012]

In order to achieve the above object, the invention according to claim 1 divides a predetermined job into a plurality of jobs in a plurality of computer systems connected to each other through a communication line. An inquiry unit is provided on the distributed processing system for processing the job execution status to inquire the execution status of the job from each computer system and obtains the answer, and creates an inquiry result regarding the execution status of the job based on the answer from each computer system. In a job execution status inquiry device in a distributed processing system having an inquiry result creation unit, the inquiry result creation unit is provided with a history information storage unit that holds the execution status of a job as history information, and the inquiry unit is provided with the job Inquiry dispatching unit that simultaneously inquires the history information to all computer systems sharing It is characterized in.

According to a second aspect of the present invention, in the job execution status inquiry device in the distributed processing system according to the first aspect, the history information as a response to the inquiry by the inquiry transmission section is sent to the inquiry section as a job. Is provided with an inquiry receiving unit for receiving an arbitrary order which is not restricted by the execution order of.

According to a third aspect of the present invention, in the job execution state inquiry device in the distributed processing system according to the second aspect, the history information includes data relating to a job execution start time, and the inquiry result creation unit includes: A history information analysis unit for arranging the history information received by the inquiry receiving unit in the order of job execution based on the execution start time is provided.

[0015]

The operation of the present invention having the above construction is as follows. That is, according to the invention of claim 1,
The execution status of the job handled by each computer system is stored in the history information storage unit as history information. Then, the inquiry transmission unit inquires the computer system in charge of the job of the history information all at once regardless of the job execution order. Then, the required time becomes shorter than inquiring in the order of job execution.

According to the second aspect of the present invention, the inquiry receiving unit receives the history information from each computer system in an arbitrary order. Therefore, even if a certain computer system fails and transmission cannot be performed, the failure occurs. Does not interfere with the transmission of any other computer system.

According to the third aspect of the present invention, the history information is arranged according to the data regarding the execution start time of the job, and in the order in which the jobs are actually executed. Therefore, even if the user who inquires about the execution status of the job does not know the execution order of the jobs in advance, an inquiry result that makes it easy to grasp the execution status of the entire job is created.

[0018]

【Example】

(1) Configuration of Embodiment An embodiment of the present invention will be described below with reference to the drawings. First, the configuration of this embodiment is as follows. That is, as shown in FIG. 1, a plurality of computer systems 2, 3, 4, 5, 6, 7 are connected via a communication medium 1 in a bus type. These computer systems have displays and have shared or separate printers. An inquiry unit 8 and an inquiry result creation unit 9 are configured on each computer system. The inquiry unit 8 includes an inquiry transmission unit 8a and an inquiry reception unit 8b,
The inquiry result creation unit 9 includes a history information storage unit 9a and a history information analysis unit 9b. The inquiry transmission unit 8a has a multicast function and uses this multicast to inquire about the job execution status. Here, multicast means on the network
It is a communication method for performing broadcast transmission to a group of nodes that are logically related by a certain upper level rule. Therefore, the inquiry transmission unit 8a in the present embodiment.
Has a function of simultaneously inquiring the execution status of jobs to the destination addresses (broadcast addresses) of all the computer systems in charge of jobs related to one job.

The history information storage section 9a stores the execution status of jobs in each computer system as history information. As shown in FIG. 2, the history information includes the identifier of the job in charge, the job requester, the job start time,
It is composed of the job end time and. Here, the job identifier is an identifier for uniquely identifying each job. The job requester is the computer system that requested the job.

The inquiry receiving unit 8b receives history information sent from each computer system in response to an inquiry request from the inquiry sending unit 8 in an arbitrary order (for example, in the order of transmission) regardless of the job execution order. Is. Further, the history information analysis unit 9b arranges the history information received by the inquiry receiving unit 8b in the order of job execution according to the job start time data in the history information.

(2) Operation of the Embodiment The operation of this embodiment having the above-mentioned structure is as follows. Here, a case will be described as an example in which the job is composed of four jobs A, B, C, and D, and jobs to be performed in the order of jobs A, B, C, and D are executed. The computer system 2 requests jobs A, B, C, and D to the computer systems 3, 4, 5, and 6, respectively. Then, a part of the job B that the computer system 4 is in charge of (sub-job B ′) is
It shall be executed by the computer system 7. Here, the job B executed by the computer systems 4 and 7,
B ′ shall be executed in parallel.

With the above settings, it is assumed that the job A is completed and the job B and the sub-job B'are currently executed in parallel. The history information stored in each computer system at this stage is as shown in FIG. A case where the computer system 2 makes an inquiry about a job in this state will be described. First, as shown in FIG. 3, the inquiry transmission unit 8 of the computer system 2 simultaneously makes an inquiry to the computer systems 3, 4, 5, 6, 7 by using multicast. That is, the inquiries are simultaneously made to all the computer systems in charge of the job. Each computer system that has received the inquiry receives the history information extracted from the history information storage unit 9 and the identifier of each computer system (identifier for identifying who is the responder) in the inquiry receiving unit 10 of the computer system 2. Send to. Here, the order in which the responses are received from each computer system to the computer system 2 is the order in which the jobs are executed (in this embodiment, 3 → 4 →
5 → 6) does not always match and is arbitrary (usually,
The order in which the answers were sent).

For example, it is assumed that a reply is returned to the computer system 2 as shown in FIGS. Then, the received information becomes as shown in the table of FIG. In this table, the information in the upper row indicates that the information returned earlier. Based on this information, the history information analysis unit 11 of the computer system 2 creates a job inquiry result. That is, the history information analysis unit 11
As shown in FIG. 7, the received history information is sorted in ascending order of start time. According to this inquiry result, it is understood that the job A is finished, the job B is currently being executed, and the sub-job B ′ of the job B is also being executed in parallel. The fact that B'is a B sub-job can be known from the information that the requester of B'is the computer system 4. The above query result is
The information is output to the display or printer of the computer system 2 and the user grasps the execution status of the entire work.

(3) Effects of the Embodiment The effects of this embodiment as described above are as follows. That is, since the inquiry transmission unit 8a simultaneously makes an inquiry to each computer system in charge of each job using multicast, the time until an answer is obtained from each computer system is shortened. Therefore, even if the user does not know the order in which the jobs are executed in advance, the execution status of the jobs can be quickly known. In particular, the computer system 4 causes a part of the job B to be executed by another computer system 7 to execute a sub-job B ′.
Even if the request is made as, the person who inquires the job does not need to know this.

Further, since the inquiry receiving unit 10 receives the history information in an arbitrary order regardless of the job execution order, even if there is no transmission from a certain computer system due to a failure or the like, it will be transmitted from another computer system. Is surely obtained. Therefore, it is possible to know the execution status of the entire business within the range of a normal computer system.

Further, the received history information is rearranged by the history information analysis unit 11 in the order of the earliest start time and output to a display or a printer. Therefore, the user can easily obtain the execution status of the entire job without knowing in advance the order in which the jobs will be executed at the time of inquiry.

(4) Other Embodiments The present invention is not limited to the above embodiments, and for example, the number of connected computer systems is seven.
The number is not limited to one and may be more or less than that in the above embodiment as long as it is plural. The wiring form of the network is not limited to the bus type, and may be a star type, a ring type, or the like.

[0028]

As described above, according to the present invention, by providing an inquiry transmission unit for making inquiries to each computer system at once, the job execution state in the distributed processing system can be grasped in a short time. A job execution status inquiry device in a distributed processing system can be provided.

Further, by providing an inquiry receiving unit for arbitrarily receiving history information from each computer system, even if some computer systems in the distributed processing system fail, it is possible to grasp the execution status of the entire work. A job execution status inquiry device in a distributed processing system can be provided.

Further, by providing a history information analysis unit, a distributed processing system in which a user who makes an inquiry about a job can create an inquiry result in which the execution state of the entire job can be easily grasped without knowing the execution order of the job in advance. It is possible to provide a job execution status inquiry device in the above.

[Brief description of drawings]

FIG. 1 is a configuration diagram of an embodiment of a job execution status inquiry device in a distributed processing system of the present invention.

FIG. 2 is a diagram showing history information stored in each computer system at a certain point in the embodiment of FIG.

FIG. 3 is an explanatory diagram showing an example of an inquiry according to the embodiment of FIG.

FIG. 4 is an explanatory diagram showing an example of an answer according to the embodiment of FIG.

5 is an explanatory diagram showing an example of an answer according to the embodiment of FIG.

6 is a diagram showing history information at the time of receiving a reply in the embodiment of FIG.

FIG. 7 is a diagram showing an inquiry result created based on received history information in the embodiment of FIG.

[Explanation of symbols]

 1 ... Communication medium 2, 3, 4, 5, 6, 7 ... Computer system 8 ... Inquiry section 8a ... Inquiry sending section 8b ... Inquiry receiving section 9 ... Inquiry result creating section 9a ... History information storage section 9b ... History information analysis section

Claims (3)

[Claims] 1. A distributed processing system that processes a predetermined job by a plurality of computer systems connected to each other via a communication line by a plurality of jobs, and executes the job execution state in each computer system. In a job execution state inquiry device in a distributed processing system, which comprises an inquiry unit for inquiring and obtaining an answer thereof, and an inquiry result creating unit for creating an inquiry result regarding an execution state of a job based on an answer from each computer system, The result creation unit is provided with a history information storage unit that holds the execution status of jobs as history information, and the inquiry unit is an inquiry transmission unit that simultaneously inquires the history information to all computer systems that share the work. Job execution status inquiry in the distributed processing system characterized by the provision Location. 2. The inquiry unit is provided with an inquiry receiving unit for receiving the history information as an answer to an inquiry made by the inquiry sending unit in an arbitrary order that is not restricted by the order of execution of jobs. 1. A job execution status inquiry device in the distributed processing system according to 1. 3. The history information includes data relating to a job execution start time, and the history information received by the inquiry reception unit is sent to the inquiry result creation unit based on the execution start time. 3. The job execution status inquiry device in the distributed processing system according to claim 2, further comprising a history information analysis unit arranged in order.