Patent ID: 9720785
Date: 2017-08-01
CPC Classifications: G06F,H04L

Claim:
1. An apparatus comprising: at least one processor; a memory coupled to the at least one processor; a streams manager residing in the memory and executed by the at least one processor, the streams manager executing a streaming application that comprises a flow graph that includes a plurality of operators that process a plurality of data tuples, wherein the flow graph defines at least one tuple window that each comprises at least one of the plurality of data tuples; and a checkpoint mechanism that uses a plurality of periodic time periods for taking checkpoints, and dynamically adjusts a time for taking a checkpoint to be at a selected time different than at an end of one of the plurality of periodic time periods based on predicted size of the at least one tuple window in the streaming application, wherein the predicted size of the at least one tuple window determines a storage requirement for taking the checkpoint, wherein the checkpoint mechanism selects the selected time for taking the checkpoint based on the storage requirement for taking the checkpoint and based on predicted backpressure in at least one portion of the flow graph.