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
