flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gyula Fóra <gyula.f...@gmail.com>
Subject Re: Discard out-of-order events
Date Fri, 29 Jul 2016 08:57:31 GMT
Hi Max,

So if I understand correctly the window operators now, by default,  discard
late elements?
Is this documented somewhere?

Gyula

Maximilian Michels <mxm@apache.org> ezt írta (időpont: 2016. júl. 29., P,
10:40):

> Hi!
>
> I'm not sure whether I understand your question. The purpose of Event
> Time is to be able to process out-of-order events. Do you want to
> discard late elements? In the upcoming Flink 1.1.0 you can set the
> `allowedLateness` on a windowed stream. The default is 0, so late
> elements are discarded; late elements are elements which arrive after
> the Watermark has reached the operator.
>
> Cheers,
> Max
>
> On Thu, Jul 28, 2016 at 6:49 PM, Kevin Jacobs <kevin.jacobs@cern.ch>
> wrote:
> > Is it possible to discard events that are out-of-order (in terms of event
> > time)?
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message