add metrics to mysql cdc connector

baisui1981 · baisui1981 · commit 4117e8aab2ee · 2025-07-05T08:30:13.000+08:00
diff --git a/tis-incr/tis-flink-extends/src/main/java/com/qlangtech/plugins/incr/flink/metrics/TISPBReporter.java b/tis-incr/tis-flink-extends/src/main/java/com/qlangtech/plugins/incr/flink/metrics/TISPBReporter.java
@@ -70,6 +70,7 @@ public void notifyOfAddedMetric(Metric metric, String metricName, MetricGroup gr
         String[] scope = group.getScopeComponents();
 // 输出示例：["jobmanager", "job_MyJob", "task_Source", "operator_Map", "0"]
         super.notifyOfAddedMetric(metric, metricName, group);
+        String name = group.getMetricIdentifier(metricName, this);
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -70,6 +70,7 @@ public void notifyOfAddedMetric(Metric metric, String metricName, MetricGroup gr`
`70`	`70`	`String[] scope = group.getScopeComponents();`
`71`	`71`	`// 输出示例：["jobmanager", "job_MyJob", "task_Source", "operator_Map", "0"]`
`72`	`72`	`super.notifyOfAddedMetric(metric, metricName, group);`
	`73`	`+ String name = group.getMetricIdentifier(metricName, this);`
`73`	`74`	`}`
`74`	`75`
`75`	`76`	`@Override`