Hi all,

When attempting to upgrade a running Dataflow pipeline from SDK 2.51.0 to
2.52.0, an incompatibility warning is surfaced that prevents pipeline
upgrade:


> The Coder or type for step .../PubsubUnboundedSource has changed


Was there an intentional coder change introduced for PubsubMessage in
2.52.0?  I didn't note anything in the release notes
https://beam.apache.org/blog/beam-2.52.0/ nor recent changes in
PubsubMessageWithAttributesCoder[1].  Specifically the step uses
`PubsubMessageWithAttributesCoder` via
`PubsubIO.readMessagesWithAttributes()`

Thanks!


[1]
https://github.com/apache/beam/blob/90e79ae373ab38cf4e48e9854c28aaffb0938458/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessageWithAttributesCoder.java#L36

Reply via email to