Re: Early events

2016-11-21 Thread Juan Rodríguez Hortalá
That makes sense, thanks for your answer. Greetings, Juan On Mon, Nov 21, 2016 at 9:11 AM, Aljoscha Krettek wrote: > Hi, > yes, Flink is expected to buffer those until the watermark catches up with > their timestamp. > > Cheers, > Aljoscha > > On Sun, 20 Nov 2016 at 06:18 Juan Rodríguez Hortal

Re: Early events

2016-11-21 Thread Aljoscha Krettek
Hi, yes, Flink is expected to buffer those until the watermark catches up with their timestamp. Cheers, Aljoscha On Sun, 20 Nov 2016 at 06:18 Juan Rodríguez Hortalá < juan.rodriguez.hort...@gmail.com> wrote: > Hi, > > There was a bug in my code, I was assigning the timestamps wrong and that > is

Re: Early events

2016-11-19 Thread Juan Rodríguez Hortalá
Hi, There was a bug in my code, I was assigning the timestamps wrong and that is why it looked like early events where assigned processing time. Surprisingly enought my test works both ok with early events. In fact I have modified my test data generator to generate early events or late events, and