fix: registerMetricsForNumCompletedCheckpoints

PeterZh6 · Sep 18, 2024 · e52d89c · e52d89c
1 parent 8b7a3f5
commit e52d89c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/SourceExactlyMetric.java b/...sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/SourceExactlyMetric.java
@@ -110,6 +110,7 @@ public SourceExactlyMetric(MetricOption option, MetricGroup metricGroup) {
                 registerMetricsForCurrentFetchEventTimeLag();
                 registerMetricsForCurrentEmitEventTimeLag();
                 registerMetricsForDeserializeTimeLag();
+                registerMetricsForNumCompletedCheckpoints(new ThreadSafeCounter());
                 registerMetricsForNumDeserializeSuccess(new ThreadSafeCounter());
                 registerMetricsForNumDeserializeError(new ThreadSafeCounter());
                 registerMetricsForNumSnapshotCreate(new ThreadSafeCounter());