Hi Kirill,
Your understanding of checkpointing is very good. Just a couple of
additions.
Incremental checkpoints usually help when you have a low number of changed
keys. Afaik in statefun, the keys correspond to a function address (name X
id).
So if you have few function addresses and all of them
Hello
I'm new to Flink. I am playing with Stateful Functions and have a question
about checkpoints and how they work.
Some configuration details:
state.backend: rocksdb
state.backend.incremental: true
execution.checkpointing.mode: AT_LEAST_ONCE
As far as I know:
1. There is a sync checkp
