[FLINK-23749] Testing Window Join

• Type: Improvement
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.14.0
• Component/s: Tests
• Labels: release-testing
• Assignee: Martijn Visser
• Reporter: Jing Zhang
• Created: 13/Aug/21 03:13
• Updated: 14/Sep/21 10:18
• Resolved: 14/Sep/21 10:18

Description

The window join requires the join on condition contains window starts equality of input tables and window ends equality of input tables. The semantic of window join is the same to the DataStream window join.

SELECT ...
FROM L [LEFT|RIGHT|FULL OUTER] JOIN R -- L and R are relations applied windowing TVF
ON L.window_start = R.window_start AND L.window_end = R.window_end AND ...

In the future, we can also simplify the join on clause to only include the window start equality if the windowing TVF is TUMBLE or HOP . Currently, the windowing TVFs must be the same of left and right inputs. This can be extended in the future, for example, tumbling windows join sliding windows with the same window size.

Currently, Flink not only supports Window Join which follows after Window Aggregation.  But also supports Window Join which follows after Windowing TVF .

Issue Links

• Testing discovered: FLINK-24186 Disable single rowtime column check for collect/print