如何获取 flink 作业的延迟数答案

【问题标题】：How to get the latency number of flink job如何获取 flink 作业的延迟数
【发布时间】：2017-07-28 16:28:11
【问题描述】：

我知道 flink 开箱即用地收集延迟指标，但我想知道如何获取工作的延迟数据。

我是否必须使用自定义报告器（例如石墨）来查看延迟？

我在 flink Dashboard 中看到了延迟指标，但是当我添加 sink operator 的延迟时没有数据。如果这不是延迟数据，它是什么？

谢谢。

顺便说一下，我用的是Flink V1.2.1。

【问题讨论】：

标签： apache-flink

【解决方案1】：

Flink Dashboard 只能显示单个值。但是您可以使用 REST api 检查延迟。 URL 应如下所示：

http://localhost:8081/jobs/f184a26ee033d5448042c18de57499a1/vertices/91f34222e409e97879611b1fd334816e/metrics?get=0.Sink__Unnamed.latency

回复将如下所示：

[
  {
    id: "0.Sink__Unnamed.latency",
    value: "{LatencySourceDescriptor{vertexID=1, subtaskIndex=0}={p99=416.0699999999999, p50=253.0, min=102.0, max=421.0, p95=378.04999999999995, mean=249.953125}}"
  }
]

您可以使用http://localhost:8081/jobs/ 查找您的作业ID，然后使用http://localhost:8081/jobs/<job-id>/vertices/ 在您的执行图中选择一个运算符。 http://localhost:8081/jobs/<job-id>/vertices/<operator-id>/metrics 将显示可用的指标。

【讨论】：

从 Flink 1.5 开始，端点是 /jobs/metrics（参见 stackoverflow.com/a/50982071/1236613）。