osdir.com


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Enabling Flink’s checkpointing


Hi Olga,

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.

Best,
Andrey

> On 15 Nov 2018, at 18:20, Olga Luganska <treble77@xxxxxxxxxxx> wrote:
> 
> 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