如何检查Flink Yarn会话是否已经在运行



如何检查Flink Yarn会话是否已经在Flink集群中运行?

特别是我想通过编程性检查此会话,如果不是作为自动部署的一部分运行的会话。

https://ci.apache.org/projects/flink/flink/flink-docs-stable/ops/cli.html似乎没有任何明显的命令。

如果它已经在运行,则Flink的REST API将在某些端口上收听。您可以使用curl server:8081之类的东西来查看是否可用。如果不运行,Curl将以7状态退出,以表明该连接被拒绝。

我最终使用了以下方式:

/usr/bin/yarn application -list 2>/dev/null | grep -i "Flink session" | awk '{print $1}'`

相关内容

  • 没有找到相关文章

最新更新