Re: [I] Duplicated data files when to use FlinkSink upsert mode to stream upsert records [iceberg]

["SML0127 (via GitHub)" <gi...@apache.org>]

SML0127 commented on issue #4552:
URL: https://github.com/apache/iceberg/issues/4552#issuecomment-2330521218

   
   
   
   > In upsert mode there will generate one delete data for everyone insert data, and the delete data will be write to equal delete file(if there is duplicate primary key data be write in one snapshot will add postion delete file).So, just as you see there are two files that one data file and one equal delete file.
   
   @hameizi 
   I have some question about your answer.
   Then.. how to distinguish whether equality filed in equality delete file was append by DELETE or INSERT/UPDATE_AFTER ?
   


-- 
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: issues-unsubscribe@iceberg.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org