flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Xingcan Cui <xingc...@gmail.com>
Subject Re: Collect event which arrive after watermark
Date Fri, 06 Apr 2018 12:21:06 GMT
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 <shishal.a@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/
> 


Mime
View raw message