RE: Determinism of interval joins

2022-02-02 Thread Alexis Sarda-Espinosa
Sarda-Espinosa mailto:alexis.sarda-espin...@microfocus.com>> Cc: user@flink.apache.org<mailto:user@flink.apache.org> Subject: Re: Determinism of interval joins Instead of using `reinterpretAsKeyedStream` can you use keyBey and see if the behavior gets deterministic? On Thu, Jan 27, 2022 at

RE: Determinism of interval joins

2022-01-29 Thread Alexis Sarda-Espinosa
mantics are commonly expected when handling multiple streams that need joins and so on. What do you think? Regards, Alexis. From: Robert Metzger Sent: Freitag, 28. Januar 2022 14:49 To: Alexis Sarda-Espinosa Cc: user@flink.apache.org Subject: Re: Determinism of interval joins Instead of using

Re: Determinism of interval joins

2022-01-28 Thread Robert Metzger
Instead of using `reinterpretAsKeyedStream` can you use keyBey and see if the behavior gets deterministic? On Thu, Jan 27, 2022 at 9:49 PM Alexis Sarda-Espinosa < alexis.sarda-espin...@microfocus.com> wrote: > I'm not sure if the issue in [1] is relevant since it mentions the Table > API, but it

Re: Determinism of interval joins

2022-01-27 Thread Alexis Sarda-Espinosa
I'm not sure if the issue in [1] is relevant since it mentions the Table API, but it could be. Since stream1 and stream2 in my example have a long chain of operators behind, I presume they might "run" at very different paces. Oh and, in the context of my unit tests, watermarks should be determin