beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ben Chambers (JIRA)" <>
Subject [jira] [Created] (BEAM-1655) Evaluate the PubsubUnboundedSource
Date Wed, 08 Mar 2017 18:35:38 GMT
Ben Chambers created BEAM-1655:

             Summary: Evaluate the PubsubUnboundedSource
                 Key: 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

View raw message