Ben Chambers created BEAM-1655:
----------------------------------
Summary: Evaluate the PubsubUnboundedSource
Key: BEAM-1655
URL: https://issues.apache.org/jira/browse/BEAM-1655
Project: Beam
Issue Type: Bug
Components: sdk-java-extensions
Reporter: Ben Chambers
Assignee: Davor Bonaci
This source includes a lot of assumptions & assertions that may cause problems
on runners that implement UnboundedSources differently. For example:
1. It requires that finalizeCheckpoint is called at most once.
2. It requires that the checkpoint be finalized within the pubsub timeout, or
the messages will be redelivered.
... (possibly other assumptions) ...
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
