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
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