有没有办法获得flink任务管理器的任务管理器id

falq053o  于 2021-06-25  发布在  Flink
关注(0)|答案(4)|浏览(840)

我想得到taskmanager的整数id/hash id,并使用它来报告度量。

owfi6suc

owfi6suc1#

您可以通过以下方式获得计划TaskManager的json格式输出:

curl -s "http://localhost:8081/taskmanagers/"

如果您只对taskmanager的id感兴趣,那么可以使用jq获取它(https://stedolan.github.io/jq/).
获取第一个taskmanager的id的示例:

local task_manager_id=`curl -s "http://localhost:8081/taskmanagers/" | jq -r '.taskmanagers[0].id'`
fcipmucu

fcipmucu2#

最后,我通过获取每个任务管理器运行时的应用程序容器id得到了解决方案。
容器id符合我的目的,谢谢你的见解。

bjg7j2ky

bjg7j2ky3#

你可以用公制。
在(富)用户定义函数中调用getruntimecontext().getmetricgroup().getallvariables().get(“<tm\u id>”)

cngwdvgl

cngwdvgl4#

您可以在以下位置检查将哪些任务Map到jobmanager的web前端上的哪个任务槽:http://localhost:8081. 你也有一堆指标。

相关问题