flink-cdc
flink-cdc copied to clipboard
[e2e] add pipeline e2e test for mysql connector.
This closes https://github.com/ververica/flink-cdc-connectors/issues/2859.
Add e2e test for two scenes: sync the whole database and sync sharding tables using route function. To simplify the complexity of different source/sink combinations, I plan to use MySQL as the source for all sinks and Doris as the sink for all sources. Include two latest major version of Flink, 1.17.1 & 1.18.0.
@leonardBang @GOODBOY008 PTAL.
@leonardBang can you help to rerun the failure CI of mongodb
Rebased to master.
@loserwang1024 Adding value to value e2e test is useless as values connector is designed for test, it’s different with other connectors like MySQL, StarRocks, etc.
@lvyanquan could help rebase this PR and resolve the comments as well?
@lvyanquan kindly ping
I've fixed the checkstyle failure and rebased to master.