为提高效率,提问时请提供以下信息,问题描述清晰可优先响应。
【DM版本】: 8.1.3.168
【操作系统】: x86
【CPU】:
【问题描述】:使用达梦 CDC 的时候可以同步全量数据,同步增量数据时出现 NPE
达梦 驱动版本 8.1.3.168
Flink 版本 1.18
达梦 cdc 版本 3.3.0
cdc 版本 3.3.0
按照官方文档进行了配置,开启了归档日志,对应的参数设置成了文档的推荐值
https://eco.dameng.com/community/post/202411191132168PD86B201G3HYB7NK5
Flink SQL 如下:
CREATE TABLE stresstesting_damengcdc_ods_test_source_1110_02_ri (
ID BIGINT,
NAME VARCHAR,
PRIMARY KEY(ID) NOT ENFORCED
) WITH
('username'='',
'hostname'=',
'connector'='dm-cdc',
'password'=,
'table-name'='FLINK_TEST_SOURCE_TABLE_3',
'port'='',
'database-name'='DAMENG',
'schema-name'='*');
CREATE TABLE stresstesting_dameng_ods_flink_test_sink_table_5_ri_000 (
ID BIGINT,
NAME VARCHAR,
PRIMARY KEY (ID) NOT ENFORCED
) WITH
('driver'='dm.jdbc.driver.DmDriver',
'url'='jdbc:dm://:/',
'username'='',
'connector'='jdbc',
'password'='***',
'table-name'='FLINK_TEST_SINK_TABLE_5',
);
INSERT INTO stresstesting_dameng_ods_flink_test_sink_table_5_ri_00(ID,NAME)
(SELECT * FROM stresstesting_damengcdc_ods_test_source_1110_02_ri);
其中来源表和目标表都是仅有两个字段 ID BIGINT 和 NAME VARCHAR,切 ID 为主键
