[FLINK-11668] Allow sources to advance time to max watermark on checkpoint.

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.8.0
• Fix Version/s: 1.9.0
• Component/s: Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Kostas Kloudas
• Reporter: Kostas Kloudas
• Created: 20/Feb/19 08:24
• Updated: 17/Apr/19 13:18
• Resolved: 17/Apr/19 13:18

Description

This is needed for the TERMINATE case. It will allow the sources to inject the MAX_WATERMARK before the barrier that will trigger the last savepoint. This will fire any registered event-time timers and flush any state associated with these timers, e.g. windows.