twthorn opened a new pull request, #16826: URL: https://github.com/apache/iceberg/pull/16826
## Description Fix for kafka-connect sink. Closes https://github.com/apache/iceberg/issues/15395 When the connect record value is not null, table schema is updated and evolved correctly. However, when connect record value is null, no evolution takes place, causing issues reported in https://github.com/apache/iceberg/issues/15395 and https://github.com/apache/iceberg/issues/16212. Fix this behavior by adding a new method for handling the recursive evolution on the connect record schema (only done once a recursive branch reaches a null value, then this call continues on the evolution on just the remaining nested schema). ## Verification Add tests to verify the behavior including the cases: - null value with nested evolved schema - list/map of structs with evolution - type promotion & optionality change -- 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]
