Apache Flink：REST API 检索指标值答案

【问题标题】：Apache Flink: REST API retrieve metric valuesApache Flink：REST API 检索指标值
【发布时间】：2018-12-10 14:15:31
【问题描述】：

我启动了延迟跟踪并通过了 REST API 的 /jobs/metrics。得到以下信息：

{"id":"latency.source_id.cbc357ccb763df2852fee8c4fc7d55f2.operator_id.e5ebb093256018a0621f548fbe118f8a.operator_subtask_index.0.latency_p75"}, {"id":"lastCheckpointExternalPath"}, {"id":"latency.source_id.cbc357ccb763df2852fee8c4fc7d55f2.operator_id.55785f9edccd37ac9093dea77018f09d.operator_subtask_index.0.latency_max"}, {"id":"latency.source_id.cbc357ccb763df2852fee8c4fc7d55f2.operator_id.55785f9edccd37ac9093dea77018f09d.operator_subtask_index.0.latency_p999"}, .....

Q：为什么不显示具体数值？如何正确使用 API？

感谢您的帮助。

【问题讨论】：

标签： apache-flink flink-streaming

【解决方案1】：

请参阅doc。

/jobs/metrics返回metrics的id，你需要查询job id和metric id：

GET taskmanagers/ABCDE/metrics?get=metric1,metric2

获取如下值：

[
  {
    "id": "metric1",
    "value": "34"
  },
  {
    "id": "metric2",
    "value": "2"
  }
]

【讨论】：

你说的是GET /jobmanager/metrics返回的JVM相关指标信息，不是/jobs/metrics返回的延迟指标信息。
他的回答也适用于 /jobs/metrics。