[FLINK-5387] Lightweight Event Time Window

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.1.3
• Component/s: API / DataStream
• Assignee: Unassigned
• Reporter: Syinchwun Leo
• Created: 22/Dec/16 08:44
• Updated: 14/Feb/19 09:42
• Resolved: 14/Feb/19 09:42

Description

When a new data coming and insert into Event Time Window, windowSize/slide subWindows are generated. and the data is copied to all of these subWindows. When the value of windowSize/slide is very big, redundancy is large, and this will slow the RocksDB's checkpoint. Event Window should redesigned, and candidate design is similar as Session window, only generating a pane(aligned with slide) when a new data come instead of generating a series of subWindows