[ https://issues.apache.org/jira/browse/BEAM-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773413#comment-16773413 ]
Ahmet Altay commented on BEAM-6678: ----------------------------------- https://github.com/apache/beam/pull/7874 - cp'ed changes to the release branch, closing. > FlinkRunner does not checkpoint partition view of watermark holds > ----------------------------------------------------------------- > > Key: BEAM-6678 > URL: https://issues.apache.org/jira/browse/BEAM-6678 > Project: Beam > Issue Type: Bug > Components: runner-flink > Reporter: Maximilian Michels > Assignee: Maximilian Michels > Priority: Major > Fix For: 2.11.0 > > Time Spent: 2h > Remaining Estimate: 0h > > The FlinkRunner does not persist its view of the per-partition Watermark > holds. This can lead to elements to be considered late after restoring from a > savepoint or resuming a failed pipeline. > Similar to the approach in BEAM-6650, we can recover the Watermarks by > iterating through the keys of the state backend during recovery. -- This message was sent by Atlassian JIRA (v7.6.3#76005)