注册

达梦CDC连接器空指针异常

Megalovania 2025/11/12 301 0

为提高效率,提问时请提供以下信息,问题描述清晰可优先响应。
【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 为主键
cb40727845601df7999abca1a518d1b7.png

回答 0
暂无回答
扫一扫
联系客服