[ https://issues.apache.org/jira/browse/BEAM-1300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Thomas Groh resolved BEAM-1300. ------------------------------- Resolution: Fixed Fix Version/s: 0.5.0 > The DirectRunner resumes from unfinalized checkpoints > ----------------------------------------------------- > > Key: BEAM-1300 > URL: https://issues.apache.org/jira/browse/BEAM-1300 > Project: Beam > Issue Type: Bug > Components: runner-direct > Reporter: Thomas Groh > Assignee: Thomas Groh > Fix For: 0.5.0 > > > This is a bug in the order in which Source methods are invoked relative to > checkpoint methods. Sources may only resume from finalized checkpoints, but > the implementation of Unbounded Read in the DirectRunner finalizes a > checkpoint after a reader has been created but before it is started. It must > be finalized before the reader is created. -- This message was sent by Atlassian JIRA (v6.3.15#6346)