linfey90 opened a new pull request, #5619: URL: https://github.com/apache/iceberg/pull/5619
Usually when we update data, we have an -U and +U in Changelog.But When we add a condition in CDC synchronization, such as rate>10, we insert a data greater than 10 in the source, such as mysql, and the condition will be met. When we modify the data less than 10, the condition will not be met, and only a -U will be transmitted. If does not delete the data when UPDATE_BEFORE, our results will be incorrect,so I think UPDATE_BEFORE is also necessary for UPSERT, when there have not UPDATE_AFTER. the sql like: insert into hive_catalog.dm_ods.basic_ods select * from dm_mapping.default_catalog.basic_source where rate > 20; -- 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]
