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

我想获得任务管理器的整体ID /哈希ID和报告指标。有没有办法获得flink taskmanagers的任务管理器ID

2017-04-19 mukh007

尝试Flink WebUI RESTful API：**/taskmanagers **，它将返回正在运行的TaskManagers及其实例ID的列表。 – David

我想通过代码/ some api以编程方式获得它 – mukh007

啊，我明白了。您可以使用RpcService.connect（）获取一个** JobMasterGateway **，它提供了一个RPC方法，** requestRegisteredTaskManagers **来检索所有注册的TaskManager。 – David

最后我通过获取YARN应用容器ID为得到了解决每个任务管理器都遇到了。

容器ID适合我的目的，谢谢你的所有见解。

2017-06-06 18:53:06 mukh007

您可以检查哪些任务被映射到JobManager网络前端的http://localhost:8081上的哪个任务插槽。你也有很多指标。

2017-04-20 10:12:20 ImbaBalboa

我正在寻求从代码本身访问此，我也需要发布我自己的应用程序特定的指标。 – mukh007

您可以使用该公制的系统。

在一个（丰富的）用户定义的函数调用getRuntimeContext（）。getMetricGroup（）。getAllVariables（）。获得（ “< tm_id >”）

2017-04-21 05:54:43

这给了我taskId，即如果多个任务部署在同一个节点上，我会为这些任务获得不同的并行ID，而不是全局taskmanager_id（对于jvm） – mukh007

你试过了吗？因为任务ID可通过“”访问。 –

是的，但任务ID是一个随机哈希，我需要可预测的数字，例如1，2，3 ..... – mukh007

回答