Details
-
Improvement
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.12.0
-
Added execution.checkpointing.unaligned.forced
Description
For rescaling of Unaligned Checkpoints added in 1.12, EndOfChannelRecovery and upstream alignment will be added.
However, this alignment won't work for iterative jobs.
There is a need to
- pass this info to subtasks (whether is iterative)
- validate on startup
- a flag to skip validation
Attachments
Issue Links
- blocks
-
FLINK-19856 Add EndOfChannelRecovery rescaling epoch
- Resolved
- links to