flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Olga Luganska <trebl...@hotmail.com>
Subject Enabling Flink’s checkpointing
Date Thu, 15 Nov 2018 17:20:33 GMT

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

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
View raw message