Re: Flink Event Time order

Ok, thanks for letting us know that you solved it! > On 4. May 2017, at 07:41, Björn Zachrisson wrote: > > Hi, > > No that is only a subset of the code. > I realized it was the multiple sink/parallelization that caused my "mystique > behavior". > So when sorting each bucket-result for them sel

Re: Flink Event Time order

Is that linked code your actual code? I don’t see the watermark emission code or the priority queue code. Best, Aljoscha > On 1. May 2017, at 16:02, Björn Zachrisson wrote: > > Hi, > > According to the link https://pastebin.com/409Z0tSc > > > I'm trying to st

Flink Event Time order

Hi, According to the link https://pastebin.com/409Z0tSc I'm trying to start building my flink application based on "taxi drives"-example. I use a priority queue to add the events and emitting watermarks every period+1min where period normally is 30minutes. The thing is that the events seems to