You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by Yubin Li <ly...@gmail.com> on 2024/10/30 03:18:57 UTC

[DISCUSS][FLINK-36547] Add option to retain `RowKind` sematics for cdc formats

Hi everyone,

As official docs said, `RowKind` semantics have been changed after encode:
-U -> -D, +D -> +I. In fact, we also have a demand to make it consistent in
many scenarios, such as those that require different processing of -U/-D
and +U/+I.

I have taken advantage of the difference between UPDATE_BEFORE and
UPDATE_AFTER to implement the feature and made it run well in business.
please see details in jira [1].

Looking forward to your feedback :)

[1] https://issues.apache.org/jira/browse/FLINK-36547

Best,
Yubin