Hello, By reading Flink documentation I see that to enable checkpointing we need to:
1. Enable checkpointing at the execution environment. 2. Make sure that your source/sink implements either CheckpointedFunction or ListCheckpointed interfaces? Is #2 a must, and how checkpointing mechanism is affected if your source does not implement mentioned above interfaces? (I see example of using RuntimeContext accessing keyed state) Please explain. Thank you very much, Olga Sent from my iPhone
