You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/03 10:43:00 UTC

[jira] [Closed] (FLINK-21090) Add E2E/ITCase test for checkpoints after tasks finished

     [ https://issues.apache.org/jira/browse/FLINK-21090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dawid Wysakowicz closed FLINK-21090.
------------------------------------
    Fix Version/s: 1.14.0
       Resolution: Implemented

Implemented in:
* master
** f6e784772dc89e197efe6d7a5f52a513ced6682a..36f607c9fdff11e67cd1768bb48295f83da3e350
* 1.14.0
** 87cb9ee68587c876e7ed6701ac4bb0a6b7d037aa..7b1c5a6801da123901ca68909be321b3cbf2caf7

> 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
>             Fix For: 1.14.0
>
>
> 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)