版本flink1.11.0
请问下各位大佬MetricQueryService这个类中定义的四种类型metric的值是怎么更新的?比如kafka的current-offset是Gauge类型,MetricQueryService中gauges这个map对应的current-offset的值怎么更新的呢?只看到addMetric这个方法是put值的,但是通过本地调试和代码走读,这个方法只是一开始注册用的,运行过程如何更新metric的?
--
Sent from:
http://apache-flink.147419.n8.nabble.com/