Patent ID: 9396050
Filing Date: 2016-07-19
CPC Classification: G06F

Claim Text:
1. A distributed execution system that executes a first distributed program and a second distributed program connected through a pipe, comprising: a processor; an output-side pipe worker that operates on a first node comprising the processor, and transmits output-data acquired from an output-side worker to an input-side pipe worker, the output-side worker being realized by the first distributed program and operating on the first node; the input-side pipe worker that operates on a second, receives the output data from the output-side pipe worker, and transfers the output data to an input-side worker, the input-side worker being realized by the second distributed program and operating on the second node; and a pipe master including a worker controlling unit, wherein the output-side pipe worker includes: wherein the input-side pipe worker includes: a second communication unit that receives the output data and the output-side sequence number transmitted from the output-side pipe worker; and a retaining unit that retains the latest output-side sequence number that is received by the second communication unit, wherein the worker controlling unit of the pipe master acquires the latest output-side sequence number retained in the retaining unit of the input-side pipe worker, and transmits the acquired latest output-side sequence number to the output-side pipe worker as the input-side sequence number.