Patent ID: 8719367

Claim:
A distributed processing system, comprising: a plurality of data processing apparatuses; a distributed processing management apparatus, connected to the plurality of data processing apparatuses via a network, which manages the plurality of data processing apparatuses in a distributed processing of an application by the plurality of data processing apparatuses, the distributed processing management apparatus including: a processing capacity information acquiring unit which acquires, from the plurality of data processing apparatuses, information on the respective processing capacities of the data processing apparatuses via the network; an application information acquiring unit which acquires information on an application that includes a plurality of tasks to be processed by the data processing apparatuses, the information including an execution sequence of the plurality of tasks contained in the application and information on transfer of data between the tasks; a task distributing unit which determines which of the plurality of tasks contained in the application are to be processed by which of the data processing apparatuses, based on the information on the respective processing capacities of the data processing apparatuses acquired by the processing capacity information acquiring unit; a task transmitting unit which transmits tasks to a data processing apparatus determined by the task distributing unit; and a task information conveying unit which conveys information concerning a source apparatus of input data required by the respective task to the data processing apparatus executing the respective task, and the data processing apparatus including: a task acquiring unit which acquires the task; a task executing unit which executes the task; a task information acquiring unit which acquires information concerning a source apparatus of data required by the task; a communication task generator which generates a send task to make the source apparatus transmit data required by the task to the data processing apparatus, and transmits the send task to the source apparatus, when the source apparatus is another data processing apparatus, which is different from the data processing apparatus, connected to the data processing apparatus via the network; and a send task executing unit which executes, if a send task is acquired from an apparatus executing a subsequent task, the send task and transmits the data required by the subsequent task to the apparatus executing the subsequent task.