[ https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15862290#comment-15862290 ]
Jingsong Lee commented on BEAM-1393: ------------------------------------ Totally agree! {{AbstractStreamOperator}} will check the type of {{this}} and invoke {{checkpointKeyGroup}} in {{snapshotState()}}. ({{initializeState}} is similar) Looking forward to contributing back to Flink. I think we do not need store {{pushedBackWatermark}} in state anymore. We can maintain it in memory and restore it by traversing pushed-back events. > Update Flink Runner to Flink 1.2.0 > ---------------------------------- > > Key: BEAM-1393 > URL: https://issues.apache.org/jira/browse/BEAM-1393 > Project: Beam > Issue Type: Improvement > Components: runner-flink > Reporter: Aljoscha Krettek > Assignee: Jingsong Lee > > When we update to 1.2.0 we can use the new internal Timer API that is > available to Flink operators: {{InternalTimerService}} and also use broadcast > state to store side-input data. -- This message was sent by Atlassian JIRA (v6.3.15#6346)