Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
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) ...