apache-flink - Flink 延迟指标未显示

Question

在本地环境中运行 Flink 1.5.0 时，我试图通过 REST（类似于http://localhost:8081/jobs/e779dbbed0bfb25cd02348a2317dc8f1/vertices/e70bbd798b564e0a50e10e343f1ac56b/metrics）获取延迟指标，但没有对latency.

所有这一切都是在启用延迟跟踪的情况下进行的，我通过与调试器确认LatencyMarksEmitter正在发出标记来确认这一点。

我做错了什么？

标签： apache-flink

Answer 1

在 1.5 中，延迟度量不是针对任务而是针对作业公开的，原因是延迟度量固有地包含有关多个任务的信息。您必须改为查询“ http://localhost:8081/jobs/e779dbbed0bfb25cd02348a2317dc8f1/metrics ”。