同一个作业有两套flinkcdc同步脚本出错

[wanghaininggg]

同一个作业有同步两张表，同一个连接不同数据库的表，2.0.2可以正常运行，再高的版本2.1.0，2.2.0等都报图中的错误。随机找不到一张表。

[wanghaininggg]

后面测试同一个作业有两个source，两个source的源在同一个数据连接下，但属于两个账号，能读的数据库的权限不一样，就报这个错误

[wanghaininggg]

tableEnv.executeSql ( "CREATE TABLE srt_source_whntestdoublelist (Id VARCHAR,PRIMARY KEY (Id) NOT ENFORCED) WITH ('connector'='mysql-cdc','hostname'='','port'='3306','username'='user_prod','password'='','database-name'='productcenter_fat','table-name'='basic_datadictionary','debezium.database.history.store.only.monitored.tables.ddl'='true','debezium.database.history.skip.unparseable.ddl'='true','debezium.decimal.handling.mode'='string','debezium.snapshot.locking.mode'='none')" );
tableEnv.executeSql ( "CREATE TABLE srt_sink_whntestdoublelist (Id VARCHAR,PRIMARY KEY (Id) NOT ENFORCED) WITH ('connector'='jdbc','url'='','username'='user_datamp','password'='','table-name'='whntest4')" );
tableEnv.executeSql ( "CREATE TABLE srt_source_whntestdouble2 (id VARCHAR,name VARCHAR,key_field_name VARCHAR,PRIMARY KEY (id) NOT ENFORCED) WITH ('connector'='mysql-cdc','hostname'='','port'='3306','username'='user_usercenter','password'='','database-name'='usercenter2021_fat','table-name'='basic_datadictionary','debezium.database.history.store.only.monitored.tables.ddl'='true','debezium.database.history.skip.unparseable.ddl'='true','debezium.decimal.handling.mode'='string','debezium.snapshot.locking.mode'='none')" );
tableEnv.executeSql ( "CREATE TABLE srt_sink_whntestdouble2 (Id VARCHAR,PRIMARY KEY (Id) NOT ENFORCED) WITH ('connector'='jdbc','url'='','username'='user_datamp','password'='','table-name'='whntest5')" );

StatementSet statement = tableEnv.createStatementSet ();
statement.addInsertSql ( "INSERT INTO srt_sink_whntestdoublelist SELECT Id FROM srt_source_whntestdoublelist" );
statement.addInsertSql ( "INSERT INTO srt_sink_whntestdouble2SELECT id AS Id FROM srt_source_whntestdouble2" );
statement.EXECUTE ();