t3hw commented on PR #14797: URL: https://github.com/apache/iceberg/pull/14797#issuecomment-3666879233
> We did a test with this PR branch with properties in kafka connect for sink connector on AWS > iceberg.tables.use-dv: "true" > iceberg.tables.write-props.format-version: "3" > > We found the table was created in version 2 in metadata file. So this upsert & DV support is for version 2 tables only ? > The upsert mode for insert/update/delete worked as expected for all tables with PK=id. > Yeah, it's a limitation. I should have probably made a note about it above, but it is kind of out of scope for this PR. What I ended up doing is writing some code that interfaces with the iceberg catalog outside of kafka connect and initilizes the table ahead of time with the correct format version -- 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]
