lostluck commented on issue #33815: URL: https://github.com/apache/beam/issues/33815#issuecomment-2845098829
That definitely sounds like it could be explained by the lack of runner idicatedcheckpoints, especially if the PeriodicImpulse is used to trigger a downstream poll of the PubSub broker. It could depend on the PubSub source transform too. Ultimately we intend a prism to support the "standard" PubSub Urn beam has, but that's a later step. On Thu, May 1, 2025, 8:36 AM Avery Nguyen ***@***.***> wrote: > *avery-nguyen-verily* left a comment (apache/beam#33815) > <https://github.com/apache/beam/issues/33815#issuecomment-2845085191> > > Just to confirm, you are using a flatten transform to put all the sources > into one PCollection, right? > > yes > > — > Reply to this email directly, view it on GitHub > <https://github.com/apache/beam/issues/33815#issuecomment-2845085191>, or > unsubscribe > <https://github.com/notifications/unsubscribe-auth/ADKDOFJMP47RCI6JCPKHMKT24I5RHAVCNFSM6AAAAABWFTLIRWVHI2DSMVQWIX3LMV43OSLTON2WKQ3PNVWWK3TUHMZDQNBVGA4DKMJZGE> > . > You are receiving this because you were mentioned.Message ID: > ***@***.***> > -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: github-unsubscr...@beam.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
