I have a Flink application (v 1.4.2) where I have enabled checkpointing
with an interval of 200 ms.
This is what I have configured in my driver program:
env.enableCheckpointing(checkpointInterval,
CheckpointingMode.EXACTLY_ONCE);
CheckpointConfig config = env.getCheckpointConfig();
config.enableExternalizedCheckpoints(ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);
In the JobManager logs, I see multiple entries saying "Checkpoint
triggered".
I would like to clarify whether the JobManager is triggering the checkpoint
every 200 ms? Or does the JobManager only initiate the checkpointing and
the TaskManager do it on its own?
Regards,
James
