Hi,

I am playing with Schemas in Beam and conversion between types. I am
experimenting with Convert transform to convert PCollection of POJOs to
Protobufs, but get a failure about schemas not being compatible.

The root cause is that FieldType are not passing `equivalent()` check
because of difference in metadata as protobuf add there a proto_number
https://github.com/apache/beam/blob/v2.19.0/sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java#L818

Is it correct that metadata should be strictly equal to pass field type
equivalence check, or not?

Thanks,
Jozef

Reply via email to