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)
