我知道flink会收集开箱即用的延迟指标，但我想知道如何获得我的工作延迟数据 .
我是否必须使用自定义报告器（例如石墨）来查看延迟？
我看到flink仪表板中有延迟指标，但是当我添加接收器操作员的延迟时没有数据 . 如果这不是延迟数据，它是什么？
谢谢 .
我顺便使用Flink V1.2.1 .
Flink仪表板只能显示单个值 . 但是您可以使用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 将显示可用的指标 .
http://localhost:8081/jobs/
http://localhost:8081/jobs/<job-id>/vertices/
http://localhost:8081/jobs/<job-id>/vertices/<operator-id>/metrics
1 回答
Flink仪表板只能显示单个值 . 但是您可以使用REST api检查延迟 . URL应如下所示：
答案如下：
您可以使用
http://localhost:8081/jobs/查找作业ID，然后使用http://localhost:8081/jobs/<job-id>/vertices/在执行图中选择运算符 .http://localhost:8081/jobs/<job-id>/vertices/<operator-id>/metrics将显示可用的指标 .