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

Posted to issues@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2022/07/05 06:26:00 UTC

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

Yun Gao created FLINK-28386:
-------------------------------

             Summary: 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


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)