flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andrey Zagrebin <and...@data-artisans.com>
Subject Re: Enabling Flink’s checkpointing
Date Mon, 19 Nov 2018 10:39:56 GMT
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@hotmail.com> 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


Mime
View raw message