State & Fault Tolerance
In this section you will learn about the APIs that Flink provides for writing stateful programs. Please take a look at Stateful Stream Processing to learn about the concepts behind stateful stream processing.
Where to go next?
- Working with State: Shows how to use state in a Flink application and explains the different kinds of state.
- The Broadcast State Pattern: Explains how to connect a broadcast stream with a non-broadcast stream and use state to exchange information between them.
- Checkpointing: Describes how to enable and configure checkpointing for fault tolerance.
- Queryable State: Explains how to access state from outside of Flink during runtime.
- State Schema Evolution: Shows how schema of state types can be evolved.
- Custom Serialization for Managed State: Discusses how to implement custom serializers, especially for schema evolution.