[ https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724093#comment-17724093 ]
Jiang Xin edited comment on FLINK-28386 at 5/19/23 3:38 AM: ------------------------------------------------------------ Hi [~pnowojski], I'm going to work on this. I agree with you that only checking sources finished is not enough, but would it be simpler to just check all sink operators are finished? was (Author: jiang xin): Hi [~pnowojski], I'm working on this. I agree with you that only checking sources finished is not enough, but would it be simpler to just check all sink operators are finished? > 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 > 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)