a8356555 commented on issue #11573:
URL: https://github.com/apache/iceberg/issues/11573#issuecomment-2489959870

   > What are the records generated by the MySQL CDC connector?
   > 
   > You are using upsert mode in FlinkSink.
   > 
   > In upsert mode when an update happens, Flink expects an unchanged primary 
key. Removes the old values for a given primary key, and insets a new record.
   > 
   > When the record is updated in a way that the primary key is changed, then 
it is not really an update in upsert mode. It should be a delete and an insert 
instead. It is the responsibility of the input stream to generate the correct 
records.
   > 
   > You can use `write.upsert.enabled` set to `false` if the MySQL connector 
is able to generate a retract stream.
   
   But my use case requires upsert, so in this scenario, using status as the 
partition key is not suitable, right?


-- 
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-unsubscr...@iceberg.apache.org

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


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

Reply via email to