flink-cdc
flink-cdc copied to clipboard
once db contains one no primary key ,this job ,no error and go on .
Describe the bug(Please use English) A clear and concise description of what the bug is.
Environment :
- Flink version : 1.13.5
- Flink CDC version: 2.2.0
- Database and version: mysql 5.7.38
To Reproduce Steps to reproduce the behavior:
-
Thes test data :
-
The test code : MySqlSource mysqlSource = MySqlSource.builder() .hostname("192.168.XX.XX") .port(3306) .username("root") .password("root")
.databaseList("db01") .tablList(".*") .startupOptions(StartupOptions.initial()) .deserializer(new JsonDebeziumDeserializationSchema()) .build();
-
The error : no throws error , but get data Incomplete。for example , one db contains 3 tables , first table has primary key , sucessfully get data, secondly table no primary key , this code dont throws error and job dont go on, The final result is, only get first table data . so ...
Additional Description If applicable, add screenshots to help explain your problem.