Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id A24EA200C68 for ; Wed, 3 May 2017 10:56:25 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id A0E92160BB5; Wed, 3 May 2017 08:56:25 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id E8420160BAA for ; Wed, 3 May 2017 10:56:24 +0200 (CEST) Received: (qmail 83415 invoked by uid 500); 3 May 2017 08:56:18 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 83405 invoked by uid 99); 3 May 2017 08:56:18 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 03 May 2017 08:56:18 +0000 Received: from aljoschas-mbp.fritz.box (dslb-084-059-068-070.084.059.pools.vodafone-ip.de [84.59.68.70]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 125AB1A0312; Wed, 3 May 2017 08:56:17 +0000 (UTC) From: Aljoscha Krettek Message-Id: Content-Type: multipart/alternative; boundary="Apple-Mail=_DCA797DE-A419-4B7C-AE24-3AEA7555B9FF" Mime-Version: 1.0 (Mac OS X Mail 10.3 \(3273\)) Subject: Re: Flink Event Time order Date: Wed, 3 May 2017 10:56:15 +0200 In-Reply-To: Cc: user@flink.apache.org To: =?utf-8?Q?Bj=C3=B6rn_Zachrisson?= References: X-Mailer: Apple Mail (2.3273) archived-at: Wed, 03 May 2017 08:56:25 -0000 --Apple-Mail=_DCA797DE-A419-4B7C-AE24-3AEA7555B9FF Content-Transfer-Encoding: quoted-printable Content-Type: text/plain; charset=utf-8 Is that linked code your actual code? I don=E2=80=99t see the watermark = emission code or the priority queue code. Best, Aljoscha > On 1. May 2017, at 16:02, Bj=C3=B6rn Zachrisson = wrote: >=20 > Hi, >=20 > According to the link https://pastebin.com/409Z0tSc = >=20 > I'm trying to start building my flink application based on "taxi = drives"-example. >=20 > I use a priority queue to add the events and emitting watermarks every = period+1min where period normally is 30minutes.=20 >=20 > The thing is that the events seems to come in an chaotic order. >=20 > My expectation would be that they would come based on their original = time since i emitt watermarks after each and every "item". >=20 > This is a proof of concept application. > Can anyone guide me to my errors here please? >=20 > Best Regards --Apple-Mail=_DCA797DE-A419-4B7C-AE24-3AEA7555B9FF Content-Transfer-Encoding: quoted-printable Content-Type: text/html; charset=utf-8 Is that linked code your actual code? I don=E2=80=99t see the = watermark emission code or the priority queue code.

Best,

Aljoscha

On = 1. May 2017, at 16:02, Bj=C3=B6rn Zachrisson <bjozac@gmail.com> = wrote:

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 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

= --Apple-Mail=_DCA797DE-A419-4B7C-AE24-3AEA7555B9FF--