n...@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 9:49 PM Alexis Sarda-Espinosa
mailto:a
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 `reinterpretAsKeyedStream` can you
022 1:30 PM
> *To:* user@flink.apache.org
> *Subject:* Determinism of interval joins
>
>
> Hi everyone,
>
>
>
> I’m seeing a lack of determinism in unit tests when using an interval
> join. I am testing with both Flink 1.11.3 and 1.14.3 and the relevant bits
> of my pipeli
22 1:30 PM
To: user@flink.apache.org
Subject: Determinism of interval joins
Hi everyone,
I’m seeing a lack of determinism in unit tests when using an interval join. I
am testing with both Flink 1.11.3 and 1.14.3 and the relevant bits of my
pipeline look a bit like this:
keySelector1 = …
ke
Hi everyone,
I'm seeing a lack of determinism in unit tests when using an interval join. I
am testing with both Flink 1.11.3 and 1.14.3 and the relevant bits of my
pipeline look a bit like this:
keySelector1 = ...
keySelector2 = ...
rightStream = stream1
.flatMap(...)
.keyBy(keySelector1)
