flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Björn Zachrisson <bjo...@gmail.com>
Subject Flink Event Time order
Date Mon, 01 May 2017 14:02:12 GMT

According to the link https://pastebin.com/409Z0tSc

I'm trying to start building my flink application based on "taxi

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

View raw message