Re: Event processing time with lateness

On Fri, Jun 3, 2016 at 6:47 AM, Kostas Kloudas wrote: > To see a relatively more complex example of such a trigger and how to > implement it, > you can have a look at this implementation: >

Re: Event processing time with lateness

Hi Igor, you might be interested in this doc about how we want to improve handling of late data and some other things in the windowing API: https://docs.google.com/document/d/1Xp-YBf87vLTduYSivgqWVEMjYUmkA-hyb4muX3KRl08/edit?usp=sharing I've sent it around several times but you can never know

Re: Event processing time with lateness

Super cool stuff On Fri, Jun 3, 2016 at 10:55 AM, Kostas Kloudas wrote: > You are welcome! > > > On Jun 3, 2016, at 4:40 PM, Igor Berman wrote: > > thanks Kosta > > On 3 June 2016 at 16:47, Kostas Kloudas >

Re: Event processing time with lateness

thanks Kosta On 3 June 2016 at 16:47, Kostas Kloudas wrote: > Hi Igor, > > To handle late events in Flink you would have to implement you own custom > trigger. > > To see a relatively more complex example of such a trigger and how to > implement it, > you can have a

Event processing time with lateness

Hi according to presentation of Tyler Akidau https://docs.google.com/presentation/d/13YZy2trPugC8Zr9M8_TfSApSCZBGUDZdzi-WUz95JJw/present Flink supports late arrivals for window processing, while I've seen several question in the userlist regarding late arrivals and answer was - sort of "not for