fix: SourceExactlyMetric failed to instantiate without inlong.metric.…

…labels set
PeterZh6 · Sep 19, 2024 · 865ec15 · 865ec15
1 parent b7cc498
commit 865ec15
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ors/postgres-cdc/src/main/java/org/apache/inlong/sort/postgre/DebeziumSourceFunction.java b/...ors/postgres-cdc/src/main/java/org/apache/inlong/sort/postgre/DebeziumSourceFunction.java
@@ -236,7 +236,7 @@ public void open(Configuration parameters) throws Exception {
         this.executor = Executors.newSingleThreadExecutor(threadFactory);
         this.handover = new Handover();
         this.changeConsumer = new DebeziumChangeConsumer(handover);
-        if (sourceExactlyMetric == null) {
+        if (sourceExactlyMetric == null && metricOption != null) {
             sourceExactlyMetric = new SourceExactlyMetric(metricOption, getRuntimeContext().getMetricGroup());
         }
         if (deserializer instanceof RowDataDebeziumDeserializeSchema) {