yuzelin

The whole project is built successfully after I skip the `flink-yarn-tests` module. I think the [CI compile error](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=39902&view=logs&j=52b61abe-a3cc-5bde-cc35-1bbe89bb7df5&t=54421a62-0c80-5aad-3319-094ff69180bb]) will be fixed by other issue. 

We have pushed some fixes to solve the `pure virtual method called` in Flink test, please rebase master.

The same problem of E2E test I have met before. I've pushed some commits to try to solve the problem. You can rebase master.

Hi, can you solve the conflicts?

Seem this PR is not active now. I will continue to work on it.

@umeshdangat I'm working on merging these codes into the master branch. When it is done, you can create a PR to support your needed types.

@harveyyue Glad to hear from you! I just start to this. It's good if you are willing to continue to work on this.

Thanks your suggestion! Actually I'm working on support logical deletion in Kafka CDC. I am willing to do some works later.

The problem is that flink-kafka-connector will be removed from flink-1.18 repo, so the 1.18-snapshot kafka connector are outdate. We should wait for the flink-1.18 release and then modify the POM.

> > > The problem is that flink-kafka-connector will be removed from [flink-1](https://issues.apache.org/jira/browse/FLINK-1).18 repo, so the 1.18-snapshot kafka connector are outdate. We should wait for the [flink-1](https://issues.apache.org/jira/browse/FLINK-1).18 release and then...