Yes, CheckpointListener will enable you to listen for completed checkpoints. I think that you should put the the values in state before returning from the snapshot method, though, to prevent data loss.
And regarding your other question: yes, when a snapshot is ongoing the invoke() method will not be called. > On 12. Jun 2017, at 19:12, rhashmi <rizhas...@hotmail.com> wrote: > > I think CheckpointListener? > > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Use-Single-Sink-For-All-windows-tp13475p13653.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.
