0
点赞
收藏
分享

微信扫一扫

FlinkSQL报错--jdbc java.net.ConnectException: Connection refused (Connection refused)

前程有光 2022-02-10 阅读 161

背景

解决方案

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'
);
举报

相关推荐

0 条评论