Hi Tengda,
Which sink version do you use?
I have recently (Flink 1.18, 1.19) added the metrics to the initialization
context for the committers for the new SinkV2 API [1]. With this you have a
place to collect the desired metrics.
I hope this helps,
Peter
[1]
https://cwiki.apache.org/confluence/p
Hi Flink team,
We want to add customized metrics for measuring “user-facing/end-to-end
latency” in Flink application.
Per this post
https://stackoverflow.com/questions/56578919/latency-monitoring-in-flink-application,
the suggestion is to add a histogram metric in the sink operator myself, whic
