背景
FlinkSql 通过jdbc连接 Mysql
解决方案
需要仔细检查以下连接信息
连接驱动版本(mysql8.x、mysql5.x),连接的数据库地址、端口,连接的用户名密码等
CREATE TABLE sink_demo (
id INT primary key,
name STRING,
description STRING
) with(
'connector' = 'jdbc',
'driver' = 'com.mysql.cj.jdbc.Driver',
'url' = 'jdbc:mysql://127.0.0.1:3307/FlinkCDC',
'username'='root',
'password'='root123',
'table-name' = 'SinkDemo',
'sink.buffer-flush.max-rows'='1',
'sink.buffer-flush.interval'='0'
);