Tutorial by Examples

Checkpointing configuration is done in two steps. First, you need to choose a backend. Then, you can specify the interval and mode of the checkpoints in a per-application basis. Backends Available backends Where the checkpoints are stored depends on the configured backend: MemoryStateBackend...

The code Here is a simple flink application using a stateful mapper with an Integer managed state. You can play with the checkpointEnable, checkpointInterval and checkpointMode variables to see their effect: public class CheckpointExample { private static Logger LOG = LoggerFactory.getLogge...