Apache Flink运行WordCount示例时无法连接8081端口求助

• 确认Flink集群是否正常启动
  执行jps命令，检查是否存在JobManagerRunner和TaskManagerRunner进程。如果没有，说明集群启动失败，前往./log目录查看JobManager日志（文件命名类似flink-*-jobmanager-*.log），排查启动失败的具体原因，比如端口占用、配置错误等。

• 检查端口配置与占用情况

  1. 查看conf/flink-conf.yaml中的端口配置：默认情况下Flink的JobManager RPC端口是6123，Web UI端口是8081。若你修改过端口配置，需确保提交作业时使用正确的端口。
  2. 检查8081端口是否被其他进程占用：
     • Linux/macOS执行：netstat -tulpn | grep 8081
     • Windows执行：netstat -ano | findstr :8081
       若端口被占用，可终止占用该端口的进程，或修改Flink配置文件中的对应端口（比如rest.port或jobmanager.rpc.port），之后重启集群。

• 显式指定JobManager地址端口提交作业
  尝试在提交命令中明确指定JobManager的RPC地址和默认端口：

  ./bin/flink run -m localhost:6123 ./examples/batch/WordCount.jar --input test.txt --output out.txt
  

• 本地模式快速测试
  若只是入门测试，无需启动集群，直接用本地模式运行作业：

  ./bin/flink run -m local ./examples/batch/WordCount.jar --input test.txt --output out.txt
  

• 重新启动集群
  先彻底停止集群：

  ./bin/stop-cluster.sh
  

  用jps确认所有Flink进程已终止后，再重新启动集群：

  ./bin/start-cluster.sh
  

  等待3-5秒后再提交作业。

内容的提问来源于stack exchange，提问作者ΚΩΝΣΤΑΝΤΙΝΟΣ ΟΡΦΑΝΟΥΔΗΣ