Re: Temporal tables not behaving as expected

2019-01-22 Thread Chris Miller
Message -- From: "Fabian Hueske" To: "Chris Miller" Cc: "user" Sent: 22/01/2019 11:23:23 Subject: Re: Temporal tables not behaving as expected Hi, The problem is that you are using processing time which is non-deterministic. Both inputs are consumed at the same

Re: Temporal tables not behaving as expected

2019-01-22 Thread Fabian Hueske
Hi, The problem is that you are using processing time which is non-deterministic. Both inputs are consumed at the same time and joined based on which record arrived first. The result depends on a race condition. If you change the input table to have event time attributes and use these to

Temporal tables not behaving as expected

2019-01-21 Thread Chris Miller
Hi all, I'm new to Flink so am probably missing something simple. I'm using Flink 1.7.1 and am trying to use temporal table functions but aren't getting the results I expect. With the example code below, I would expect 4 records to be output (one for each order), but instead I'm only seeing