[ https://issues.apache.org/jira/browse/BEAM-283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Maximilian Michels reassigned BEAM-283: --------------------------------------- Assignee: Maximilian Michels > CheckpointMark.finalize() is not called in Flink Source Wrapper > --------------------------------------------------------------- > > Key: BEAM-283 > URL: https://issues.apache.org/jira/browse/BEAM-283 > Project: Beam > Issue Type: Bug > Components: runner-flink > Reporter: Aljoscha Krettek > Assignee: Maximilian Michels > -- This message was sent by Atlassian JIRA (v6.3.4#6332)