[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17640306#comment-17640306 ]
Steven Zhen Wu commented on FLINK-29801: ---------------------------------------- This is an important missing part of coordinator. I am also very interested in this for FLIP-27 Iceberg source. [~MengYue] [~ruanhang1993] do you want to start a discussion thread of the FLIP-274? I have two questions. 1. There is already an empty `OperatorCoordinatorMetricGroup` interface in Flink. what is the reason to add this method to the interface? {code} /** * The total number of events received since the operator coordinator started. */ Counter getNumEventsInCounter(); {code} 2. How can the metric group be passed to `SourceCoordinatorContext`? > OperatorCoordinator need open the way to operate metricGroup interface > ---------------------------------------------------------------------- > > Key: FLINK-29801 > URL: https://issues.apache.org/jira/browse/FLINK-29801 > Project: Flink > Issue Type: Improvement > Components: Runtime / Metrics > Reporter: yuemeng > Assignee: yuemeng > Priority: Major > Labels: pull-request-available > > Currently, We have no way to get metric group instances in OperatorCoordinator > In some cases, we may report some metric in OperatorCoordinator such as Flink > hudi integrate sceneļ¼ some meta will send to operator coordinator to commit > to hdfs or hms > but we also need to report some metrics in operator coordinator for monitor > purpose -- This message was sent by Atlassian Jira (v8.20.10#820010)