Flink SQL Client连接MinIO报Connection Refused及连接地址异常排查

核心问题定位 #

你的日志显示SQL Client尝试连接0.0.0.0:8081而非jobmanager:8081，说明SQL Client未正确获取JobManager的服务地址配置，默认使用了本地地址0.0.0.0，导致无法在Docker网络中定位到JobManager服务。

具体解决步骤 #

1. 修正Flink核心配置文件flink-conf.yaml #

确保所有Flink组件（JobManager、TaskManager、SQL Client）的flink-conf.yaml中配置正确的JobManager地址与端口：

jobmanager.rpc.address: jobmanager
# 确认端口匹配：若你的JobManager RPC端口不是默认6123而是8081，需同步配置
jobmanager.rpc.port: 8081

如果通过Docker Compose挂载配置文件，要保证SQL Client容器挂载的flink-conf.yaml包含上述配置。

2. 在Docker Compose中为SQL Client传递环境变量 #

在docker-compose.yml的SQL Client服务块中，添加环境变量强制指定JobManager地址：

services:
  sql-client:
    ...
    environment:
      - FLINK_JOBMANAGER_ADDRESS=jobmanager
      - FLINK_JOBMANAGER_RPC_PORT=8081

该环境变量会覆盖默认配置，确保SQL Client启动时指向正确的JobManager服务。

3. 启动SQL Client时显式指定JobManager地址 #

若上述配置仍不生效，启动SQL Client时直接传入JVM参数强制覆盖设置：

./sql-client.sh embedded -Djobmanager.rpc.address=jobmanager -Djobmanager.rpc.port=8081

4. 验证配置生效 #

进入SQL Client容器后，执行以下SQL命令确认当前配置：

SET jobmanager.rpc.address;
SET jobmanager.rpc.port;

若返回值为jobmanager和8081，说明配置已正确加载；若仍为0.0.0.0，则需检查配置文件是否被正确挂载或环境变量是否生效。

5. 区分RPC端口与Web UI端口 #

注意：Flink默认JobManager RPC端口为6123，Web UI端口为8081。若日志显示连接8081，需确认是否误将Web UI端口当作RPC端口使用——若如此，需修正jobmanager.rpc.port为正确的RPC端口（如默认6123），并同步所有组件的配置。

内容的提问来源于stack exchange，提问作者Liping Huang