Sam Whittle created BEAM-9483: --------------------------------- Summary: PubsubIO.readMessagesWithAttributesWithMessageId does not work with streaming dataflow pipeline Key: BEAM-9483 URL: https://issues.apache.org/jira/browse/BEAM-9483 Project: Beam Issue Type: Bug Components: runner-dataflow Reporter: Sam Whittle
https://github.com/apache/beam/blob/d84b80b58274dc1680e61d536d7bf2077f70d6c9/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java#L1257 needs to indicate that attibutes are required for the dataflow runner to send the full pubsub message with message id. A work around is to use PubsubIO.readMessagesWithAttributesWithMessageId instead. -- This message was sent by Atlassian Jira (v8.3.4#803005)