[ https://issues.apache.org/jira/browse/BEAM-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Beam JIRA Bot updated BEAM-2629: -------------------------------- Labels: stale-assigned (was: ) > Adding timestamp and id attributes to pubsub messages with no other > attributes causes an exception. > --------------------------------------------------------------------------------------------------- > > Key: BEAM-2629 > URL: https://issues.apache.org/jira/browse/BEAM-2629 > Project: Beam > Issue Type: Bug > Components: io-java-gcp > Affects Versions: 2.2.0 > Reporter: Nigel Kilmer > Assignee: Nigel Kilmer > Priority: P2 > Labels: stale-assigned > > I'm trying to use PubsubIO.writeProtos along with a timestamp and id > attribute. When PubsubIO tries to write the messages to my topic, it throws a > PipelineExecutionException with this cause: > Caused by: java.lang.UnsupportedOperationException > at java.util.AbstractMap.put(AbstractMap.java:209) > at > org.apache.beam.sdk.io.gcp.pubsub.PubsubJsonClient.publish(PubsubJsonClient.java:148) > at > org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSink$WriterFn.publishBatch(PubsubUnboundedSink.java:249) > at > org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSink$WriterFn.processElement(PubsubUnboundedSink.java:285) > Looks like the problem is that PubsubJsonClient attempts to add the timestamp > and id attributes to a map which may be empty and immutable if no other > attributes are specified on the message. I will submit a pull request with a > fix for this bug shortly. -- This message was sent by Atlassian Jira (v8.3.4#803005)