Wie bekomme ich die Latenz-Nummer von flink Job

Question

Ich weiß, flink sammelt Latenz-Messwerte out-of-Box, aber ich möchte wissen, wie bekomme ich die Latenzdaten meines Jobs.

Muss ich benutzerdefinierte Reporter (z. B. Graphit) verwenden, um die Latenz zu sehen?

Ich sah, dass es Latenz-Metriken in Flink Dashboard, aber keine Daten, wenn ich die Latenz eines Senke-Betreibers hinzugefügt. Wenn dies nicht die Latenzdaten sind, was ist das?

Vielen Dank.

Ich benutze Flink V1.2.1 übrigens.

Answer 1

Das Flink-Dashboard kann nur einzelne Werte anzeigen. Sie können die Latenz jedoch mithilfe der REST-API überprüfen. Die URL sollte wie folgt aussehen:

http://localhost:8081/jobs/f184a26ee033d5448042c18de57499a1/vertices/91f34222e409e97879611b1fd334816e/metrics?get=0.Sink__Unnamed.latency 

Und die Antwort wird wie folgt aussehen:

[ 
    { 
    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}}" 
    } 
] 

Sie können http://localhost:8081/jobs/ benutzen, um Ihre Job-ID zu finden, und dann http://localhost:8081/jobs/<job-id>/vertices/ einen Operator in Ihrer Ausführung Graph zu wählen . http://localhost:8081/jobs/<job-id>/vertices/<operator-id>/metrics zeigt die verfügbaren Messwerte an.