Flink State Processor API with Windowed CoGroup and Unaligned Checkpoints
How can I use the Flink State Processor API to process the state of a windowed CoGroup (or Join) function? The documentation does not give such an example.
Is there a way to use the Flink State Processor API to process unaligned checkpoints?
Solution
Not sure this is doable.
No, this isn't possible. (In general, the on-the-wire serializer needn't be the same as the state serializer. Unaligned checkpoints can include copies of inflight data that the state processor API can't deserialize.)