[ https://issues.apache.org/jira/browse/BEAM-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sam Whittle updated BEAM-9483: ------------------------------ Summary: PubsubIO.readMessagesWithMessageId does not work with streaming dataflow pipeline (was: PubsubIO.readMessagesWithAttributesWithMessageId does not work with streaming dataflow pipeline) > PubsubIO.readMessagesWithMessageId 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)