如何检查flink纱线会话是否已经在flink集群中运行?
特别是,我希望以编程方式检查这一点,如果会话不是作为自动部署的一部分运行,则启动该会话。
https://ci.apache.org/projects/flink/flink-docs-stable/ops/cli.html似乎没有任何明显的命令。
发布于 2019-05-05 01:35:00
如果已经在运行,Flink的REST API将监听某个端口。您可以使用诸如curl server:8081之类的工具来查看它是否可用。如果它没有运行,curl将退出,状态为7,表示连接被拒绝。
发布于 2019-05-25 06:41:00
我最终使用了这个:
/usr/bin/yarn application -list 2>/dev/null | grep -i "Flink session" | awk '{print $1}'`https://stackoverflow.com/questions/55977485
复制相似问题