Skip to content

Latest commit

 

History

History
32 lines (26 loc) · 1.28 KB

checkpoints.md

File metadata and controls

32 lines (26 loc) · 1.28 KB
Raw
title
Checkpoints

Checkpoints in Aiven for Apache Flink® are a key feature for ensuring resiliency and fault tolerance in stateful functions. By periodically creating snapshots of the data stream and storing them, checkpoints enable Flink to quickly and efficiently recover the stream's state and position in the event of a failure, ensuring that applications can continue to execute without interruption.

In the event of a failure, Aiven for Apache Flink uses these checkpoints to restore the application's state and resume processing from the last recorded reading position, allowing the application to continue as if the failure had never occurred.

Unlike traditional backups in database systems, rather than creating full copies of the data, checkpoints function more like recovery logs by periodically creating snapshots of the data stream and storing them.

graph TD;

    id5[/Older records in data stream/]-->id4[[Checkpoint barrier n-1]];
    id4 --- id3[(Checkpoint operator state)];
    id3 --- id2[[Checkpoint barrier n]];
    id2-->id1[/Newer records in data stream/];
    id3-->id6[(State backend)];

For more information, see the Apache Flink® documentation on checkpoints.