Guosmilesmile opened a new pull request, #17737: URL: https://github.com/apache/iceberg/pull/17737
Iceberg v3 defines the Avro encoding for variant: a record with `metadata` and `value` binary fields (shredding is not supported in Avro). The core avro layer (`ValueWriters.variants()` / `ValueReaders.variants()`) and the Spark bridges (`SparkAvroWriter` / `SparkPlannedAvroReader`) already implement this encoding, and the Flink Parquet bridges also support variant. However, the Flink Avro bridges do not: `FlinkAvroWriter` and `FlinkPlannedAvroReader` do not override `variant()`, so any read or write of an Avro data file containing a variant column fails with: ``` java.lang.UnsupportedOperationException: Visitor does not support variant ``` This pr aim to add support variant for Avro readers and writers. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
