[FLINK-18996] Avoid disorder for time interval join

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.18.0
• Component/s: Table SQL / Runtime
• Labels: auto-deprioritized-critical auto-deprioritized-major pull-request-available
• Assignee: Lyn Zhang
• Reporter: Benchao Li
• Created: 19/Aug/20 05:04
• Updated: 04/Apr/23 10:06
• Resolved: 27/Mar/23 13:52

Description

Currently, the time interval join will produce data with rowtime later than watermark. If we use the rowtime again in downstream, e.t. window aggregation, we'll lose some data.

 

reported from user-zh: http://apache-flink.147419.n8.nabble.com/Re-flink-interval-join-tc4458.html#none

Issue Links

• is duplicated by: FLINK-31212 Data lost on interval left join with window group
• links to: GitHub Pull Request #22014