fix: pass metric group to sourceExactlyMetric

PeterZh6 · Oct 11, 2024 · bed796d · bed796d
1 parent ae91907
commit bed796d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...r/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarTableDeserializationSchema.java b/...r/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarTableDeserializationSchema.java
@@ -86,7 +86,7 @@ public void open(DeserializationSchema.InitializationContext context, SourceConf
             keyDeserialization.open(context);
         }
         if (metricOption != null) {
-            sourceExactlyMetric = new SourceExactlyMetric(metricOption);
+            sourceExactlyMetric = new SourceExactlyMetric(metricOption, context.getMetricGroup());
         }
         valueDeserialization.open(context);
     }