[FLINK-4651] Re-register processing time timers at the WindowOperator upon recovery.

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.1.5, 1.2.0
• Component/s: API / DataStream
• Labels: windows
• Assignee: Kostas Kloudas
• Reporter: Kostas Kloudas
• Created: 21/Sep/16 08:32
• Updated: 14/Feb/17 08:58
• Resolved: 14/Feb/17 08:58

Description

Currently the WindowOperator checkpoints the processing time timers, but upon recovery it does not re-registers them with the TimeServiceProvider. To actually reprocess them it relies on another element that will come and register a new timer for a future point in time. Although this is a realistic assumption in long running jobs, we can remove this assumption by re-registering the restored timers with the TimeServiceProvider in the open() method of the WindowOperator.