flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Collect event which arrive after watermark
Date Wed, 04 Apr 2018 22:05:15 GMT
Window operators drop late events by default. When they receive a late
event, they already computed and emitted a result.
Since there is not good default behavior to hay ndle a late event in this
case, they are simply dropped.
However, Flink offers multiple ways to explicitly handle late events such
as sending them to a side output or computing and emitting an updated
result.

So, if you apply a ProcessFunction before any other operator, you can
handle all late events.

Best, Fabian

2018-04-04 23:26 GMT+02:00 shishal <shishal.a@gmail.com>:

> Thanks Fabian, My understand was that late event older than watermark is
> dropped. So processFunction wont be called for late event. So I guess my
> understanding was wrong. Or there is something more to it?
>
>
>
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.
> n4.nabble.com/
>

Mime
View raw message