[ https://issues.apache.org/jira/browse/BEAM-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ahmet Altay closed BEAM-6678. ----------------------------- Resolution: Fixed > 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)