[FLINK-29692] Support early/late fires for Windowing TVFs

• Type: New Feature
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.15.3
• Component/s: Table SQL / Planner
• Assignee: Unassigned
• Reporter: Canope Nerda
• Created: 19/Oct/22 14:17
• Updated: 17/Oct/23 09:10

Description

I have cases where I need to 1) output data as soon as possible and 2) handle late arriving data to achieve eventual correctness. In the logic, I need to do window deduplication which is based on Windowing TVFs and according to source code, early/late fires are not supported yet in Windowing TVFs.

Actually 1) contradicts with 2). Without early/late fires, we had to compromise, either live with fresh incorrect data or tolerate excess latency for correctness.