[BEAM-1300] The DirectRunner resumes from unfinalized checkpoints

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 0.5.0
• Component/s: runner-direct
• Assignee: Thomas Groh
• Reporter: Thomas Groh
• Created: 23/Jan/17 18:27
• Updated: 16/May/20 13:56
• Resolved: 15/Feb/17 18:49

Description

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.

Issue Links

• links to: GitHub Pull Request #1819