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

Dawid Wysakowicz reassigned FLINK-21087:
----------------------------------------

    Assignee: Yun Gao

> StreamTask waits for all the asynchronous step of pending checkpoint to finish
> ------------------------------------------------------------------------------
>
>                 Key: FLINK-21087
>                 URL: https://issues.apache.org/jira/browse/FLINK-21087
>             Project: Flink
>          Issue Type: Sub-task
>          Components: API / DataStream, Runtime / Checkpointing
>            Reporter: Yun Gao
>            Assignee: Yun Gao
>            Priority: Major
>              Labels: pull-request-available
>
> Currently the snapshot process contains the synchronous and asynchronous 
> steps. When a StreamTask going to finish, there might be some pending 
> checkpoints that are still running their asynchronous step. Currently 
> StreamTask would abort these pending checkpoints since checkpoints after 
> tasks finished are not support, and it need to be changed to StreamTask wait 
> for these pending checkpoint to finish.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to