[INLONG-9499][Sort] Fix typos in FlinkPulsarSource and FlinkPulsarSou…

…rceWithoutAdmin (#9500)
apache · Dec 20, 2023 · de6f3d2 · de6f3d2
1 parent 52ed84f
commit de6f3d2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...ectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/internal/FlinkPulsarSource.java b/...ectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/internal/FlinkPulsarSource.java
@@ -464,9 +464,9 @@ public void open(Configuration parameters) throws Exception {
         }
 
         if (this.deserializer != null) {
-            DynamicPulsarDeserializationSchema dynamicKafkaDeserializationSchema =
+            DynamicPulsarDeserializationSchema dynamicPulsarDeserializationSchema =
                     (DynamicPulsarDeserializationSchema) deserializer;
-            dynamicKafkaDeserializationSchema.setMetricData(sourceMetricData);
+            dynamicPulsarDeserializationSchema.setMetricData(sourceMetricData);
 
             this.deserializer.open(
                     RuntimeContextInitializationContextAdapters.deserializationAdapter(

diff --git a/...r/src/main/java/org/apache/inlong/sort/pulsar/internal/FlinkPulsarSourceWithoutAdmin.java b/...r/src/main/java/org/apache/inlong/sort/pulsar/internal/FlinkPulsarSourceWithoutAdmin.java
@@ -436,9 +436,9 @@ public void open(Configuration parameters) throws Exception {
 
         if (this.deserializer != null) {
 
-            DynamicPulsarDeserializationSchema dynamicKafkaDeserializationSchema =
+            DynamicPulsarDeserializationSchema dynamicPulsarDeserializationSchema =
                     (DynamicPulsarDeserializationSchema) deserializer;
-            dynamicKafkaDeserializationSchema.setMetricData(sourceMetricData);
+            dynamicPulsarDeserializationSchema.setMetricData(sourceMetricData);
 
             this.deserializer.open(
                     RuntimeContextInitializationContextAdapters.deserializationAdapter(