flink web.port yarn 模式无法正确配置
flink web.port can not be configured correctly in yarn mode
我想通过REST获取flink的metrics信息api,我的flink是由YARN管理的,但是在flink-conf.yaml中更改web.port配置后,更改没有影响, flink dashboard 中的 web.port 始终为 0. 所以我无法通过 REST api.
获取 flink 指标信息
环境:
ubuntu 16.04
openjdk-8
hadoop 2.7.1.2.3.6.0-3796
弗林克 1.4.0
当运行Flink on Yarn时,Flink会为webUI选择一个随机端口(0
)以避免与其他应用程序端口冲突运行在同一台机器上。
为了访问Flink web UI 你可以查询Yarn web application proxy (YarnResourceManagerURL/proxy/application_/...
)。但请注意,只有 GET 请求才能正确转发到 Yarn 应用程序。
或者,Flink 在启动 Yarn 会话时将 Web UI URL 记录到标准输出。此外,您可以从日志文件中检索所选端口。在较新的版本(>= 1.5)中,Flink 将在 INFO
级别上记录 Rest endpoint listening at hostname:port
而在旧版本中(<= 1.4 或如果使用遗留模式)Flink 将在 Web frontend listening at hostname:port
.[=15 上记录=]
我想通过REST获取flink的metrics信息api,我的flink是由YARN管理的,但是在flink-conf.yaml中更改web.port配置后,更改没有影响, flink dashboard 中的 web.port 始终为 0. 所以我无法通过 REST api.
获取 flink 指标信息环境: ubuntu 16.04 openjdk-8 hadoop 2.7.1.2.3.6.0-3796 弗林克 1.4.0
当运行Flink on Yarn时,Flink会为webUI选择一个随机端口(0
)以避免与其他应用程序端口冲突运行在同一台机器上。
为了访问Flink web UI 你可以查询Yarn web application proxy (YarnResourceManagerURL/proxy/application_/...
)。但请注意,只有 GET 请求才能正确转发到 Yarn 应用程序。
或者,Flink 在启动 Yarn 会话时将 Web UI URL 记录到标准输出。此外,您可以从日志文件中检索所选端口。在较新的版本(>= 1.5)中,Flink 将在 INFO
级别上记录 Rest endpoint listening at hostname:port
而在旧版本中(<= 1.4 或如果使用遗留模式)Flink 将在 Web frontend listening at hostname:port
.[=15 上记录=]