Hi James,
The checkpoint coordinator at the JobManager is triggering the
checkpoints by inserting checkpoint barriers into the sources. These
will get to the TaskManagers via the same communication channels data is
flowing between them. Please refer to [1] for more details.
Nico
[1]
https://ci.
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.getCheckpointC
