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: [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]
