有没有办法获得Flink TaskManagers的任务管理器ID

Question

我想获取任务管理器的积分ID/哈希ID，并使用它报告指标。

Answer 1

您可以使用公制系统。

在(Rich(用户定义的函数中呼叫getRuntimeContext((。getMetricGroup((。getAllVariables((。get("＆＃60; tm_id＆＃62;"(

Answer 2

您可以通过：

获得计划任务管理员的格式输出

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'`

Answer 3

您可以在http：//localhost：8081上检查哪些任务已映射到JobManager的Web Frontend上的哪个任务插槽。您还拥有一堆指标。

Answer 4

最后，我通过为每个任务管理器拿到纱线应用程序容器ID来获得解决方案。

容器ID的适合我的目的，但是感谢您的所有见解。