apache-flink - 如何获取Flink中所有并行度的指标？

Question

在 flink Web UI 中，我可以获得每个并行度的指标，

对于并行度 0，它喜欢:

0_filter_numberOfRecords in 

对于并行度 9，它喜欢:

9_filter_numberOfRecords in 

如何获得所有并行性的相同度量？

Answer 1

您可以通过直接查询Flink的rest端点来获取聚合指标。您需要以下信息:

1. 作业 ID jobId 标识您要查询的运算符(operator)所属的作业
2. 顶点 ID vertexId 标识您要从中检索指标的运算符

可以通过查询http://flink_cluster:port/jobs获取jobId。

可以通过查询http://flink_cluster:port/jobs/:jobId来获取vertexId，它为您提供作业信息(带有顶点ID的运算符列表) )。

获得所需的 id 后，您可以将 GET 请求发送至:

http://flink_cluster:port/jobs/:jobId/vertices/:vertexId/subtasks/metrics?get=filter.numberOfRecords

请将 :jobId 和 :vertexId 替换为各自的 ID。

如果您想要聚合子任务子范围内的指标，则可以将请求更改为 subtasks/metrics?get=filter.numberOfRecords&subtasks=0-1,4-5命令指定要包含在聚合中的子任务。