Re: How do I get the value of 99th latency inside an operator?

2020-03-10 Thread Arvid Heise
Hi Felipe, could you use the JMX metrics reporter and tap into the reported values? The proposed hacks are obviously unstable over time. On Fri, Mar 6, 2020 at 1:06 PM Aljoscha Krettek wrote: > Hi, > > I'm afraid you're correct, this is currently not exposed and you would > have to hack

Re: How do I get the value of 99th latency inside an operator?

2020-03-06 Thread Aljoscha Krettek
Hi, I'm afraid you're correct, this is currently not exposed and you would have to hack around some things and/or use reflection. AbstractStreamOperator has a field latencyStats [1], which is what holds the metrics. This is being updated from method reportOrUpdateLatencyMarker [2]. I hope

How do I get the value of 99th latency inside an operator?

2020-03-05 Thread Felipe Gutierrez
Hi community, where from the Dlink code I can get the value of 99th percentile latency (flink_taskmanager_job_latency_source_id_operator_id_operator_subtask_index_latency{operator_id="93352199ce18d8917f20fdf82cedb1b4",quantile="0.99"})? Probably I will have to hack the Flink source code to