[FLINK-19442] Unaligned checkpoints 1.1

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.13.0
• Component/s: Runtime / Checkpointing
• Labels: auto-deprioritized-major
• Assignee: Unassigned
• Reporter: Arvid Heise
• Created: 28/Sep/20 14:30
• Updated: 22/Jun/21 14:07
• Resolved: 07/Jun/21 16:15

Description

This is an umbrella issue for all efforts that increase the usability of Unaligned checkpoints.

Issue Links

• depends upon: FLINK-14551 Unaligned checkpoints

Sub-Tasks

• Support rescaling for Unaligned Checkpoints: Resolved
• Improve threading model of Unaligner: Resolved
• Fix non-blocking output availability logic.: Closed
• Optimize reading of channel state on recovery: Resolved
• Channel recovery may deadlock: Closed
• Add unaligned checkpoint config to web ui: Closed
• Add checkpoint type to checkpoint history entries in Web UI: Closed
• Add state assignment to channel state during rescaling: Resolved
• Create integration or e2e test for out of order (savepoint) barriers: Closed
• Deduplicate code between CheckpointBarrierUnaligner and CheckpointBarrierAligner: Closed
• Add EventAnnouncement priority message: Closed
• Passively timeout alignment on the inputs: Closed
• Actively timeout checkpoint barriers on the inputs: Closed
• Add support for virtual channels: Resolved