[BEAM-2982] PubSubIO.readMessages().fromSubscription(...) doesn't work with ValueProvider

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.2.0
• Component/s: io-java-gcp
• Assignee: Thomas Groh
• Reporter: Ben Chambers
• Created: 22/Sep/17 16:39
• Updated: 16/May/20 13:58
• Resolved: 25/Sep/17 20:39

Description

Originally reported on Stack Overflow:

https://stackoverflow.com/questions/46360584/apache-beam-template-runtime-context-error

—

In the `PubsubUnboundedSource#expand` method we create the PubsubSource:

https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java#L1399

Creating the PubsubSource calls `getSubscription` which attempts to get the value out of a value provider.

To support templatization, the PubsubSource needs to take the ValueProvider, and only get the subscription out at pipeline execution time.

Issue Links

• links to: GitHub Pull Request #3888