Mohsen Rezaei created FLINK-38394:
-------------------------------------
Summary: Upgrade Flink CDC to Flink 2
Key: FLINK-38394
URL: https://issues.apache.org/jira/browse/FLINK-38394
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: 1.20.1
Reporter: Mohsen Rezaei
Fix For: 2.1.1
Potentially this means removing all {{SourceFunction}} implementations in favor
of the latest {{IncrementalSource}} ones. Debezium upgrade is out of the scope
of this task, which means the Java version can bump to Java 11, without any
support for compiling/testing on Java 17 or 21.
>From a scan through the code base, here's what needs to be changed by going to
>Flink 2.1 (current stable):
* Upgrade {{SingleThreadFetcherManager}} to the latest version
* Remove table implementations of {{RichSourceFunction}} for each Database
type, and their corresponding tests
* Move all tests to the new {{StreamExecutionEnvironment}} options
* Upgrade all sinks in the pipeline modules
This assumes the existing incremental source tests have parity with their
counter source function ones.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
