| 摘要 |
<p>When reproducing the execution state after a failure has occurred in stream data processing, the disclosed data processing error recovery method, system and program make use of all window operations while minimizing the storage amount necessary for obtaining backup data. While an operator is performing stream data processing in response to a query, a query analysis unit analyses the operator, which holds the execution state of the window, etc., and the recovery points of said operator. When obtaining backup data, a backup data management unit manages the capacity necessary to obtain snapshots of the analyzed recovery points, calculates the storage area capacity needed for backing up input data up to each recovery point and the storage area capacity needed to obtain a snapshot for a window that cannot be reproduced in that way, and records the execution state by selecting a recovery point which minimizes the total value of necessary storage capacity.</p> |
