Thomas Groh created BEAM-1742: --------------------------------- Summary: UnboundedSource CheckpointMark should have more precise documentation Key: BEAM-1742 URL: https://issues.apache.org/jira/browse/BEAM-1742 Project: Beam Issue Type: Bug Components: sdk-java-core Reporter: Thomas Groh Assignee: Thomas Groh
It should describe when a Checkpoint can committed, and should have more precise definitions of when a runner is permitted to finalize it. Generally these definitions are more forgiving than what some checkpoints assume, so existing Unbounded Sources should be audited to ensure they behave correctly in this context. -- This message was sent by Atlassian JIRA (v6.3.15#6346)