[ https://issues.apache.org/jira/browse/BEAM-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sam Whittle reassigned BEAM-9483: --------------------------------- Assignee: Sam Whittle > 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 > Assignee: Sam Whittle > Priority: Minor > > 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)