fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/metrics/FlinkMetricRegistry.java [63:77]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void register(Metric metric, String metricName, AbstractMetricGroup group) {
        // use the logical group name from Fluss's metrics group as the group name
        // of Flink's metric group the metrics will be registered in
        String logicalGroupName =
                group.getLogicalScope(CharacterFilter.NO_OP_FILTER, FIELD_DELIMITER);
        MetricGroup currentMetricGroup = metricGroupForFluss.addGroup(logicalGroupName);
        // we need to put all the variables of the Fluss's metrics group to Flink's metrics group
        for (Map.Entry<String, String> variablesEntry : getVariables(group).entrySet()) {
            currentMetricGroup =
                    currentMetricGroup.addGroup(variablesEntry.getKey(), variablesEntry.getValue());
        }

        // now, register to the Flink's metrics group
        registerMetric(currentMetricGroup, metric, metricName);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/metrics/FlinkMetricRegistry.java [74:88]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void register(Metric metric, String metricName, AbstractMetricGroup group) {
        // use the logical group name from Fluss's metrics group as the group name
        // of Flink's metric group the metrics will be registered in
        String logicalGroupName =
                group.getLogicalScope(CharacterFilter.NO_OP_FILTER, FIELD_DELIMITER);
        MetricGroup currentMetricGroup = metricGroupForFluss.addGroup(logicalGroupName);
        // we need to put all the variables of the Fluss's metrics group to Flink's metrics group
        for (Map.Entry<String, String> variablesEntry : getVariables(group).entrySet()) {
            currentMetricGroup =
                    currentMetricGroup.addGroup(variablesEntry.getKey(), variablesEntry.getValue());
        }

        // now, register to the Flink's metrics group
        registerMetric(currentMetricGroup, metric, metricName);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -