[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17739931#comment-17739931 ] Dong Lin commented on FLINK-28386: -- Merged to the apache/flink master branch c6f443c92

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17724809#comment-17724809 ] Piotr Nowojski commented on FLINK-28386: Hi [~Jiang Xin], thanks! I guess it dep

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17724093#comment-17724093 ] Jiang Xin commented on FLINK-28386: --- Hi [~pnowojski], I'm working on this. I agree wit

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17714956#comment-17714956 ] Piotr Nowojski commented on FLINK-28386: [~zlzhang0122] Checkpoint could be used

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17562941#comment-17562941 ] zlzhang0122 commented on FLINK-28386: - For bounded job in this scene, IMO, maybe sav