【 使用环境 】 测试环境
【 OB or 其他组件 】OB
【 使用版本 】 obbinlog-ce-4.0.1-100000162024122511.el7.x86_64
【问题描述】在开发环境按这个文档搭建起binlog-server,按命令能执行如下命令:
然后使用flink cdc的myssql-cdc连接,flink sql代码:
CREATE TABLE sl_sys_department (
id DECIMAL(20, 0),
tenant_id DECIMAL(20, 0),
department_no VARCHAR(45),
PRIMARY KEY (id) NOT ENFORCED
) WITH (
‘connector’ = ‘mysql-cdc’,
‘hostname’ = ‘10.0.93.161’,
‘port’ = ‘8100’,
‘username’ = ‘root@pos_stage’,
‘password’ = ‘:******~’,
‘database-name’ = ‘sl_pos_base_system’,
‘table-name’ = ‘sys_department’,
‘server-time-zone’ = ‘Asia/Shanghai’
);
【复现路径】
【附件及日志】
flink cdc会报以下错误:
connection-pool-10.0.93.161:8100 - Error thrown while acquiring connection from data source
java.sql.SQLException: Variable ‘transaction_read_only’ is a GLOBAL variable
logproxy.log (17.0 MB)