Data processing failure recovery method, system and program

A fault recovery system for stream data processing performed by a computer comprising a processing unit and a storage unit,

• wherein the processing unit of the computer includes:
• a query analysis unit for analyzing operators holding the running state with respect to the operators performing stream data processing in response to a query, as well as their recovery points;
• and
• a backup data management unit for obtaining the amount of stream data at each of the recovery points analyzed by the query analysis unit, from the earliest time of an operator holding the running state with a recovery point after the particular recovery point, and the amount of the replicated data of an operator holding the running state with a recovery point before the particular recovery point, to determine the recovery point so that the sum of the amount of the stream data and the amount of the replicated data is the minimum at each of the recovery points,
• wherein the fault recovery system stores the running state of the stream data processing in the storage unit at the recovery point determined by the backup data management unit.

A fault recovery program for data processing performed by a processing unit of a computer that performs stream data processing based on a query,

• wherein the program causes the processing unit to perform the steps of:
• analyzing operators holding the running state with respect to the operators performing stream data processing in response to a query, as well as their recovery points;
• obtaining the amount of the stream data at each of the analyzed recovery points, from the earliest time of an operator holding the running state with a recovery point after the particular recovery point, and the amount of the replicated data of an operator holding the running state of a recovery point before the particular recovery point;
• determining the recovery point so that the sum of the amount of the stream data and the amount of the replicated data is the minimum at each of the recovery points;
• and
• recording the running state of the stream data processing at the determined recovery point.