flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Use Single Sink For All windows
Date Tue, 13 Jun 2017 08:01:26 GMT
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 <rizhashmi@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.

View raw message