[
https://issues.apache.org/jira/browse/FLINK-21090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-21090:
-------------------------------------
Description:
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.
was:To not affect the behavior of Flink, during the development both JM and
TM part would not be enabled via flags. After we finish all the work for JM, TM
and Recovery, we could remove these flags and enable checkpoints after tasks
finished.
> 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: Dawid Wysakowicz
> Priority: Major
>
> 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)
