Docker部署Flink集群提交任务失败，求助排查解决

1. 先理清容器网络基础 #

Docker Compose默认会为所有服务创建共享网络，jobmanager作为服务名可直接被其他容器解析。先确保docker-compose.yml中JobManager的核心端口配置正确：

• REST端口：8081（用于任务提交、仪表盘访问）
• RPC端口：6123（用于集群内部节点通信）
  无需额外限制这两个端口的网络访问，默认容器间即可互通。

2. 逐个解决提交错误 #

错误1：Connection refused: /0.0.0.0:8081 #

问题根源是提交任务时默认尝试连接容器本地的8081端口，而非JobManager服务地址。解决命令：

flink run -d -m jobmanager:8081 /path/to/your/job.jar

优先使用REST端口（8081）提交任务，比RPC端口更稳定。

错误2：Channel became inactive（指定-m jobmanager:6123后） #

该错误是RPC端口连接异常，需检查两项配置：

• 确保JobManager的环境变量正确设置RPC地址：

  jobmanager:
    environment:
      - JOB_MANAGER_RPC_ADDRESS=jobmanager
  

  必须将JOB_MANAGER_RPC_ADDRESS设为服务名，否则TaskManager和提交容器无法正确寻址RPC服务。
• 查看JobManager日志，确认日志中存在Started JobManager at jobmanager:6123，证明RPC服务正常启动。

错误3：No ExecutorFactory found（使用--target jobmanager后） #

--target参数是Flink Application模式的专属参数，而你当前使用的是Session模式，参数不匹配导致错误。

• Session模式下无需--target，直接用-m指定JobManager地址即可。
• 若要尝试Application模式，需确保Flink版本≥1.11，且命令格式适配对应部署环境（容器化Session模式不适用该参数）。

3. 验证流程 #

1. 确认JobManager正常启动：访问宿主机映射的8081端口，能打开Flink仪表盘。
2. 在提交容器内测试网络连通性：

   ping jobmanager  # 能ping通说明网络解析正常
   curl jobmanager:8081  # 返回REST接口内容说明8081端口可访问
   

3. 用正确命令提交测试任务，比如官方示例：

   flink run -d -m jobmanager:8081 /opt/flink/examples/streaming/WordCount.jar
   

   提交后去仪表盘的Running Jobs页面确认任务状态。

4. 避坑要点 #

• 提交容器内不要将FLINK_JOBMANAGER_ADDRESS设为0.0.0.0，必须指定为jobmanager服务名。
• 确保任务Jar包与Flink集群版本一致，版本不兼容会引发各类异常。
• Docker Compose中JobManager的服务名要与提交命令里的地址完全匹配，比如服务名为flink-jobmanager，则命令需写-m flink-jobmanager:8081。

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