flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

once db contains one no primary key ,this job ,no error and go on .

Open deepthinkin opened this issue 2 years ago • 0 comments

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:

  1. Thes test data :

  2. 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();
    
  3. 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.

deepthinkin avatar Jul 11 '22 00:07 deepthinkin