【 使用环境 】测试环境
【 OB or 其他组件 】oblogproxy
【 使用版本 】oceanbase3.1.4_CE_BP3、oblogproxy1.0.3、flink1.16.2
【问题描述】清晰明确描述问题
通过flink sql将数据同步至mysql，flink报错java.lang.IllegalArgumentException: Illegal argument for LogProxyClient
【复现路径】问题出现前后相关操作
相关sql：[
“CREATE TABLE ob_source(id INT,username STRING, password STRING,PRIMARY KEY(id) NOT ENFORCED) WITH (‘connector’ = ‘oceanbase-cdc’,‘scan.startup.mode’ = ‘initial’,‘username’ = ‘user@test_tenant’,‘password’ = ‘’,‘tenant-name’ = ‘test_tenant’,‘database-name’ = ‘test’,‘table-name’ = ‘user’,‘hostname’ = ‘127.0.0.1’,‘port’ = ‘2881’,‘logproxy.host’ = ‘127.0.0.1’,‘logproxy.port’ = ‘2983’,‘working-mode’ = ‘memory’)”,
“CREATE TABLE mysql_sink (id INT,username STRING,password STRING,PRIMARY KEY(id) NOT ENFORCED) WITH (‘connector’ = ‘jdbc’, ‘url’ = ‘jdbc:mysql://127.0.0.1:52306/test’, ‘table-name’ = ‘obreceive’, ‘username’ = ‘root’, ‘password’ = ‘’)”,
“insert into mysql_sink select id,username,password from ob_source”
]
【问题现象及影响】
数据同步失败
【附件】