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 <bjo...@gmail.com> wrote: > > Hi, > > According to the link https://pastebin.com/409Z0tSc > <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 come in an chaotic order. > > My expectation would be that they would come based on their original time > since i emitt watermarks after each and every "item". > > This is a proof of concept application. > Can anyone guide me to my errors here please? > > Best Regards
