Hi All,

I am debugging an issue where the periodic checkpointing has halted. I
noticed that one of the sources of my job has completed (finished). The
other sources and operators would however still be able to produce output.

Does anyone know if Flink's periodic checkpoints are supposed to continue
when one or more sources of a job are in the "FINISHED" state?

Cheers,
Niels

Reply via email to