[FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.11.0
• Fix Version/s: 1.11.0
• Component/s: Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Arvid Heise
• Reporter: Arvid Heise
• Created: 13/Mar/20 09:53
• Updated: 17/Apr/20 07:33
• Resolved: 17/Apr/20 07:33

Description

Port the unaligned checkpoint proof of concept to the new persister API of FLINK-16512.

• Adds a CheckpointBarrierUnaligner for checkpointing on first received barrier.
• Adds hooks in input/output channels to retrieve in-flight data.
• Writes in-flight data to the persister API.
• Provides basic test coverage for new components.

Issue Links

• links to: GitHub Pull Request #11507
• links to: GitHub Pull Request #11751