You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Sam Whittle (Jira)" <ji...@apache.org> on 2020/03/11 00:21:00 UTC

[jira] [Assigned] (BEAM-9483) PubsubIO.readMessagesWithAttributesWithMessageId does not work with streaming dataflow pipeline

     [ 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)