Zeppelin Flink YARN Application模式无法连接ResourceManager配置求助

问题核心 #

你的日志显示Zeppelin端的Flink解释器进程在尝试连接YARN ResourceManager的0.0.0.0:8032，而非正确的***.corpdomain:8030。虽然YARN容器内的JobManager能加载正确配置，但Zeppelin解释器启动逻辑未获取到正确的YARN配置，导致连接阻塞。

修复步骤 #

1. 让Zeppelin进程加载Hadoop/YARN配置 #

Zeppelin需要读取Hadoop的core-site.xml、yarn-site.xml才能识别YARN RM地址：

• 编辑Zeppelin的conf/zeppelin-env.sh，添加Hadoop配置目录：

  export HADOOP_CONF_DIR=/path/to/your/hadoop/etc/hadoop
  

• 重启Zeppelin服务，确保配置生效。

2. 强制在Flink解释器配置中指定YARN参数 #

进入Zeppelin UI的Interpreter页面，找到flink解释器并编辑：

• 在Properties栏添加以下配置（替换为你的实际RM地址和端口）：

  yarn.resourcemanager.address=***.corpdomain:8032
  yarn.resourcemanager.scheduler.address=***.corpdomain:8030
  

3. 配置Flink解释器的JVM参数 #

在Flink解释器的Properties中，找到flink.jvm.args，添加强制加载Hadoop配置的参数：

-Dhadoop.conf.dir=/path/to/your/hadoop/etc/hadoop

4. 验证配置生效 #

重启Flink解释器后，查看Zeppelin的解释器日志（logs/flink-interpreter-*.log），确认出现以下日志则说明配置正确：

INFO org.apache.hadoop.yarn.client.RMProxy [] - Connecting to ResourceManager at ***.corpdomain/10.9.12.200:8032

补充说明 #

直接使用./bin/flink run-application命令能成功，是因为该命令会自动读取HADOOP_CONF_DIR下的配置，但Zeppelin默认未正确加载这些配置，需手动指定。

内容的提问来源于stack exchange，提问作者Олег Заславский