[FLINK-11276] Sliding Window Optimization

• Type: New Feature
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.7.0
• Component/s: API / DataStream
• Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
• Assignee: Unassigned
• Reporter: Rong Rong
• Created: 08/Jan/19 00:41
• Updated: 25/Dec/21 22:38

Description

This umbrella JIRA focus on the improvement of the existing window operator WITHOUT changing the public facing API. Please find the initial design plan in: https://docs.google.com/document/d/1CvjPJl1Fm1PCpsuuZ4Qc-p_iUzUosBePX_rWNUt8lRw/edit?usp=sharing 
and the execution plan discussion in:
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Improvement-to-Flink-Window-Operator-with-Slicing-tt25750.html

Per the discussion in the dev mailing list. We would like to only focus on improvement in the following perspective of the WindowOperator
1. State optimization
2. Internal Window Function
3. Backward-compatibility

 

Reference: Initial improvement discussion can be found in:
https://docs.google.com/document/d/1ziVsuW_HQnvJr_4a9yKwx_LEnhVkdlde2Z5l6sx5HlY/edit?usp=sharing