Re: Enabling Flink’s checkpointing
Not sure where it is stated in the docs to make sure that source/sink implements the interface.
From what I see in the source code, if a user function does not implement CheckpointedFunction or ListCheckpointed, its operator state will just not be snapshotted, but I do not see any problem for enabled checkpoint to snapshot what supports it and success for the job.
> On 15 Nov 2018, at 18:20, Olga Luganska <treble77@xxxxxxxxxxx> wrote:
> 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,
> Sent from my iPhone