Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-1655

Evaluate the PubsubUnboundedSource

Details

    • Bug
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • None
    • Not applicable
    • io-java-gcp
    • 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) ...

      Attachments

        Activity

          People

            tgroh Thomas Groh
            bchambers Ben Chambers
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: