Hi Shishal, you could manually separate the late events from the main stream in your process function with the "side outputs"[1].
Best, Xingcan [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/side_output.html <https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/side_output.html> > On 4 Apr 2018, at 7:03 PM, shishal <shisha...@gmail.com> wrote: > > Hi Flink community members, > > I am new to flink stream processing. I am using event time processing and > keystream. > > Sorry if my question sound silly but Is there a way to collect (or log) the > late event which arrived after watermark. So somehow I need to gather this > stats for further analysis. > > Thanks, > Shishal > > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
