本文主要是介绍FlinkSQL报错--jdbc java.net.ConnectException: Connection refused (Connection refused)，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

背景

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

这篇关于FlinkSQL报错--jdbc java.net.ConnectException: Connection refused (Connection refused)的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！