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

Posted to issues@flink.apache.org by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2023/05/22 07:58:00 UTC

[jira] [Assigned] (FLINK-28386) Trigger an immediate checkpoint after all sources finished

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

Piotr Nowojski reassigned FLINK-28386:
--------------------------------------

    Assignee: Jiang Xin

> Trigger an immediate checkpoint after all sources finished
> ----------------------------------------------------------
>
>                 Key: FLINK-28386
>                 URL: https://issues.apache.org/jira/browse/FLINK-28386
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Checkpointing
>            Reporter: Yun Gao
>            Assignee: Jiang Xin
>            Priority: Major
>
> Currently for bounded job in streaming mode, by default it will wait for one more checkpoint to commit the last piece of data. If the checkpoint period is long, the waiting time might also be long. to optimize this situation, we could eagerly trigger a checkpoint after all sources are finished. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)