Hi Dawid,
Thanks for the update, I also managed to work around it by adding another
watermark assignment operator between the join and the window. I’ll have to see
if it’s possible to assign watermarks at the source, but even if it is, I worry
that the different partitions created by all my key
*Sent:* Friday, March 11, 2022 12:21 AM
*To:* user@flink.apache.org
*Cc:* pnowoj...@apache.org
*Subject:* Re: Interval join operator is not forwarding watermarks
correctly
I think I managed to create a reproducible example [1], I think it's
due to the use of window + join + window. When I r
For completeness, this still happens with Flink 1.14.4
Regards,
Alexis.
From: Alexis Sarda-Espinosa
Sent: Friday, March 11, 2022 12:21 AM
To: user@flink.apache.org
Cc: pnowoj...@apache.org
Subject: Re: Interval join operator is not forwarding watermarks
.
[1] https://github.com/asardaes/flink-interval-join-test
Regards,
Alexis.
From: Alexis Sarda-Espinosa
Sent: Thursday, March 10, 2022 7:47 PM
To: user@flink.apache.org
Cc: pnowoj...@apache.org
Subject: RE: Interval join operator is not forwarding water
I found [1] and [2], which are closed, but could be related?
[1] https://issues.apache.org/jira/browse/FLINK-23698
[2] https://issues.apache.org/jira/browse/FLINK-18934
Regards,
Alexis.
From: Alexis Sarda-Espinosa
Sent: Donnerstag, 10. März 2022 19:27
To: user@flink.apache.org
Subject: Interval
