[ https://issues.apache.org/jira/browse/FLINK-22137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Arvid Heise closed FLINK-22137. ------------------------------- Resolution: Done Thanks for reminding. This has been done eons ago ;) > Execute unaligned checkpoint test on a cluster > ---------------------------------------------- > > Key: FLINK-22137 > URL: https://issues.apache.org/jira/browse/FLINK-22137 > Project: Flink > Issue Type: Sub-task > Reporter: Arvid Heise > Priority: Major > Labels: pull-request-available > > Start application and at some point cancel/induce failure, the user needs to > restart from a retained checkpoint with > * lower > * same > * higher degree of parallelism. > To enable unaligned checkpoints, set > * execution.checkpointing.unaligned: true > * execution.checkpointing.alignment-timeout to 0s, 10s, 1min (for high > backpressure) > The primary objective is to check if all data is recovered properly and if > the semantics is correct (does state match input?). > The secondary objective is to check if Flink UI shows the information > correctly: > * unaligned checkpoint enabled on job level > * timeout on job level > * for each checkpoint, if it's unaligned or not; how much data was written -- This message was sent by Atlassian Jira (v8.20.10#820010)