flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Flink Event Time order
Date Wed, 03 May 2017 08:56:15 GMT
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 <bjozac@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


Mime
View raw message