如何獲得flink作業的延遲數

Question

我知道flink收集延遲指標，但我想知道如何獲得我作業的延遲數據。

我是否必須使用自定義記者（例如石墨）來查看延遲？

我看到flink儀表板中存在延遲度量標準，但添加了接收器運算符的延遲時沒有數據。 如果這不是延遲數據，它是什麼？

謝謝。

我正在使用Flink V1.2.1。

Answer 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將顯示可用的指標。