I believe Beam is still on Avro 1.8 and the work to make it compatible with 1.9 has yet to happen.
The Java distribution in Dataflow is dependent on which version of Beam you're using. For Beam 2.23.0 I believe it is OpenJDK 1.8.0_151-b12. On Thu, Oct 15, 2020 at 8:39 PM KV 59 <[email protected]> wrote: > Hi, > > I'm using AvroCoder for my custom type. If I use the AvroCoder and > perform these operations Object1 -> encode -> bytes -> decode -> Object2. > Object1 and Object2 are not equal. The same works locally. > > What could be the problem? I'm using Beam 2.23.0 , Avro 1.9.1 and Java > 1.8 . Do the versions matter? Also I was also looking for the Java > distribution on the DataflowRunner and couldn't find it. This might be a > lame question but does it matter? > > Thanks > Kishore >
