flinkジョブのレイテンシ数を取得する方法

Question

私はフリンクがレイテンシメトリックを収集していることを知っていますが、私は自分のジョブのレイテンシデータをどのように得ることができるか知りたいと思います。

カスタムレポータ（例：グラファイト）を使用して待ち時間を表示する必要がありますか？

シンクオペレータのレイテンシを追加したときに、フリンクダッシュボードにレイテンシメトリックがありますが、データがないことがわかりました。 これがレイテンシデータでない場合、それは何ですか？

ありがとうございます。

私は途中で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}}" 
    } 
] 

をあなたは、実行グラフの演算子を選択するためにあなたのジョブIDを見つけるためにhttp://localhost:8081/jobs/を使用して、http://localhost:8081/jobs/<job-id>/vertices/することができます。 http://localhost:8081/jobs/<job-id>/vertices/<operator-id>/metricsは利用可能な指標を表示します。