[FLINK-26565] Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: Table SQL / API, Table SQL / Planner, Table SQL / Runtime
• Labels: auto-deprioritized-minor pull-request-available
• Assignee: Unassigned
• Reporter: hehuiyuan
• Created: 10/Mar/22 03:28
• Updated: 20/Aug/23 22:35

Description

Use lateTrigger when the window maxtimestap of data is less than currentwatermark .

The data  is not discarded because the allow latency parameter.

The lateTrigger is set and the window just appeared with this data.

Issue Links

• is related to: FLINK-26498 The window result may not have been emitted when use window emit feature and set allow-latency
• links to: GitHub Pull Request #18993