【 使用环境 】测试环境
使用flinkcdc(2.4.1) + oblogproxy-ce-1.1.3-4.x 增量同步
各主机网络均互通。
【 OB or 其他组件 】
oblogproxy
【 使用版本 】
flink 1.17.1
flink-cdc 2.4.2
oblogproxy-ce-1.1.3-4.x
observer-ce-4.2.1
【问题描述】清晰明确描述问题
我的flinkcdc 任务每次都是报这个错误，flink tm日志如下：
2023-11-14 12:15:33,920 ERROR com.ververica.cdc.connectors.oceanbase.source.OceanBaseRichSourceFunction [] - LogProxyClient exception
com.oceanbase.clogproxy.client.exception.LogProxyClientException: LogProxy refused handshake request: code: 1
message: “Failed to create oblogreader”
查看logproxy日志 如下：
Duplication exist clientId: ${logproxy.client.id}, close last one: 7479373615050391559 with pid: 14306
flinksql 表定义：
CREATE TEMPORARY TABLE cdc_t_user (
user_id INT,
user_name STRING,
age INT,
PRIMARY KEY (user_id) NOT ENFORCED
) WITH (
‘connector’ = ‘oceanbase-cdc’,
‘scan.startup.mode’ = ‘initial’,
‘username’ = ‘root’,
‘password’ = ‘${ob_root_pwd}’,
‘tenant-name’ = ‘sys’,
‘database-name’ = ‘test’,
‘table-name’ = ‘t_user’,
‘hostname’ = ‘host_name’,
‘port’ = ‘2881’,
‘rootserver-list’ = ‘host_name:2882:2881’,
‘logproxy.host’ = ‘host_name’,
‘logproxy.port’ = ‘2983’,
‘jdbc.driver’ = ‘com.mysql.jdbc.Driver’,
‘compatible-mode’ = ‘mysql’,
‘connect.timeout’ = ‘60000’,
‘logproxy.client.id’ = ‘t_user_logproxy_client_id_100004_2023111411’, #启动都给一个肯定唯一的id
‘working-mode’ = ‘memory’
);
【复现路径】
每次必现，即使变更 logproxy.client.id ，杀掉oblogreader进程 → 重启 oblogproxy → 启动 flink-cdc-ob
【问题现象及影响】
【附件】