用代码编译的flink-cdc包之后去同步数据到达梦另外一张表里面会出现修改字段值其他字段值为null的情况

[Aloys24]

如图:

flink sql配置项如下：
CREATE TABLE project_member ( member_id INTEGER,project_id INTEGER,member_name VARCHAR(100),role VARCHAR(100), PRIMARY KEY (member_id) NOT ENFORCED ) WITH ( 'connector' = 'dameng-cdc',
'hostname' = 'XXXXX,
'port' = '5236',
'username' = 'SYSDBA',
'password' = 'XXXXX’,
'database' = 'XXXXX’,
'table' = 'project_member',
'server-id' = '1001',
'server-name' = 'dbserver_XXXXX’,
'adapter' = 'LogMiner' )

CREATE TABLE HDP0x5c2_project_cdc_test ( member_id INTEGER,project_id INTEGER,member_name VARCHAR(255),role VARCHAR(255), PRIMARY KEY (member_id) NOT ENFORCED ) WITH ( 'connector' = 'jdbc', 'driver' = 'dm.jdbc.driver.DmDriver', 'url' = 'jdbc:dm://XXXXX:5236/XXXX', 'username' = 'SYSDBA', 'password' = 'XXXXX’, 'table-name' = 'project_cdc_test' )