Hello, I have reported a bug https://issues.apache.org/jira/browse/FLINK-38788 and opened a PR to address it https://github.com/apache/flink-cdc/pull/4182. Looking for anyone who might be able to review? Thanks.