From bed796dc3a41a4c8fe9629957aabd0045c5738d5 Mon Sep 17 00:00:00 2001
From: PeterZh6 <zhanghengyuan1118@outlook.com>
Date: Fri, 11 Oct 2024 23:06:36 +0800
Subject: [PATCH] fix: pass metric group to sourceExactlyMetric

---
 .../sort/pulsar/table/PulsarTableDeserializationSchema.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarTableDeserializationSchema.java b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarTableDeserializationSchema.java
index 3b886f04e71..83234daae8f 100644
--- a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarTableDeserializationSchema.java
+++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/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);
     }