Hello, Is there any method available in a RichFunction to be called by Flink with a keyed context each time a checkpoint is triggered please ?
It seems that the CheckpointedFunction interface provides such a feature (snapshotState method) but only in case of operator state and it is called in a non-keyed context. Indeed, I am implementing a CoFlatMapFunction with: - a keyed state (state1) for a "control" stream (stream1) which is not often updated, - a keyed state (state2) for a "data" stream (stream2) with a high throughput and relying on a custom solution for internal state snapshot with some potential performance impact. Consequently, I don't want to trigger a state2 update for every event received in stream2 for efficiency reasons but rather update state2 based on checkpoints triggered by Flink. Best Regards, Marc
