pabloem commented on pull request #13395: URL: https://github.com/apache/beam/pull/13395#issuecomment-740705301
Hmm I see you're doing a streaming pipeline - it may be most convenient to use a batch pipeline - so instead of reading from pubsub, you just do `p.apply(Create.of(MESSAGE))`, and the pipeline should run much faster (and have fewer dependencies and likely complications) - could you try that? ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
