Hi Niels, Checkpoints can only complete if all sources are running. That's because the checkpoint mechanism relies on injecting checkpoint barriers into the stream at the sources.
Best, Fabian Am Mi., 17. Okt. 2018 um 11:11 Uhr schrieb Paul Lam <paullin3...@gmail.com>: > Hi Niels, > > Please see https://issues.apache.org/jira/browse/FLINK-249. > > Best, > Paul Lam > > 在 2018年10月17日，16:58，Niels van Kaam <ni...@vankaam.net> 写道： > > 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 > > >
