问题描述
在本地环境中运行 Flink 1.5.0 时,我试图通过 REST 获取延迟指标(类似于 http://localhost:8081/jobs/e779dbbed0bfb25cd02348a2317dc8f1/vertices/e70bbd798b564e0accodea50>) 但没有任何对
latency
的引用.
While running Flink 1.5.0 with a local environment I was trying to get latency metrics via REST (with something similar to
http://localhost:8081/jobs/e779dbbed0bfb25cd02348a2317dc8f1/vertices/e70bbd798b564e0a50e10e343f1ac56b/metrics
) but there isn't any reference to latency
.
所有这些都在启用延迟跟踪的同时,我通过与调试器检查
LatencyMarksEmitter
正在发出标记来确认这一点.
All of this while the latency tracking is enabled which I confirmed by checking with the debugger that the
LatencyMarksEmitter
is emiting the marks.
我做错了什么?
推荐答案
在 1.5 中,延迟指标不是针对任务公开的,而是针对作业公开的,原因是延迟指标本质上包含有关多个任务的信息.你必须查询 "http://localhost:8081/jobs/e779dbbed0bfb25cd02348a25cd02348a21/31.
这篇关于未显示 Flink 延迟指标的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!