Piotr Szczepanik created BEAM-8819:
--------------------------------------
Summary: AvroCoder for SpecificRecords is not serialized correctly
since 2.13.0
Key: BEAM-8819
URL: https://issues.apache.org/jira/browse/BEAM-8819
Project: Beam
Issue Type: Bug
Components: runner-core
Affects Versions: 2.16.0, 2.15.0, 2.14.0, 2.13.0
Reporter: Piotr Szczepanik
While trying to upgrade our pipelines from Beam 2.11.0 to Beam 2.16.0 we found
that our SpecificRecords used in PCollection were being decoded as
GenericRecords.
After some investigation we found the specific commit/issue that we think did
brake it:
[https://github.com/apache/beam/pull/8342/files]
https://issues.apache.org/jira/browse/BEAM-7103
After the mentioned change all AvroCoders are serialized as simple urn:
"beam:coder:avro:v1" which means they are deserialized / rehydrated as
AvroCoder<GenericRecord>.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
