joyhaldar opened a new pull request, #16097: URL: https://github.com/apache/iceberg/pull/16097
> **Draft** - opening early to let CI validate across all engine/version combinations. Will mark ready once green. ## Summary Flink's `RowData` stores UUID as bytes, but a few Flink readers/writers weren't aligned with this, causing the crashes in #14330. ## Fixes - `FlinkAvroWriter`: was sending UUID to [ValueWriters.uuids()](https://github.com/apache/iceberg/blob/8f611675e343c845c9df6e56718f1492aeb143e0/core/src/main/java/org/apache/iceberg/avro/ValueWriters.java#L89), casuing `ClassCastException` - `FlinkParquetWriters`: no UUID logic - `FlinkParquetReaders`: no UUID logic Addresses #14330 -- 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]
