有沒有辦法獲得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

回答