[ https://issues.apache.org/jira/browse/BEAM-3472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721543#comment-16721543 ]
Etienne Chauchot commented on BEAM-3472: ---------------------------------------- Thanks [~mxm] for reviving this subject. I workarounded the absence of callback by regularly watching in a thread the pipeline state and do a final push and thread stopping. But IMHO I still think such a callback could be useful. > Create a callback triggered at the end of a batch in flink runner > ----------------------------------------------------------------- > > Key: BEAM-3472 > URL: https://issues.apache.org/jira/browse/BEAM-3472 > Project: Beam > Issue Type: Improvement > Components: runner-flink > Reporter: Etienne Chauchot > Priority: Major > > In the future we might add new features to the runners for which we might > need to do some processing at the end of a batch. Currently there is not > unique place (a callback) to add this processing. -- This message was sent by Atlassian JIRA (v7.6.3#76005)