[ https://issues.apache.org/jira/browse/FLINK-21090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dawid Wysakowicz reassigned FLINK-21090: ---------------------------------------- Assignee: Roman Khachatryan (was: Dawid Wysakowicz) > Add E2E/ITCase test for checkpoints after tasks finished > -------------------------------------------------------- > > Key: FLINK-21090 > URL: https://issues.apache.org/jira/browse/FLINK-21090 > Project: Flink > Issue Type: Sub-task > Components: API / DataStream, Runtime / Checkpointing > Reporter: Yun Gao > Assignee: Roman Khachatryan > Priority: Major > Labels: pull-request-available > > We should write an E2e test for the feature. The corner cases should include: > * must check for committing side effects (notifyCheckpointComplete() was > called) > * BroadcastState > * both non keyed followed by keyed exchanges? > * aligned/unaligned checkpoints? (with unaligned checkpoint keyed > operators/subtasks can be partially finished, which is very very rare in > aligned checkpoints) - maybe it’s good enough to test only unaligned > checkpoints. -- This message was sent by Atlassian Jira (v8.3.4#803005)