[GitHub] [iceberg] stevenzwu commented on pull request #5619: Flink: Delete the data when UPDATE_BEFORE

[GitBox <gi...@apache.org>]

stevenzwu commented on PR #5619:
URL: https://github.com/apache/iceberg/pull/5619#issuecomment-1224956163

   Is this a problem with the CDC source? should CDC source generate a `DELETE` in this case?
   
   Looking at the Flink Javadoc, it seems that UPDATE_BEFORE should go with  UPDATE_AFTER hand-to-hand.
   ```
       /**
        * Update operation with the previous content of the updated row.
        *
        * <p>This kind SHOULD occur together with {@link #UPDATE_AFTER} for modelling an update that
        * needs to retract the previous row first. It is useful in cases of a non-idempotent update,
        * i.e., an update of a row that is not uniquely identifiable by a key.
        */
       UPDATE_BEFORE("-U", (byte) 1),
   ```


-- 
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