[INLONG-9075][Sort] TubeMQSource support InlongMsg format

vernedeng · Oct 19, 2023 · b62b32d · b62b32d
1 parent 18fc4c8
commit b62b32d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...s/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQDynamicTableFactory.java b/...s/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQDynamicTableFactory.java
@@ -63,7 +63,7 @@
  */
 public class TubeMQDynamicTableFactory implements DynamicTableSourceFactory, DynamicTableSinkFactory {
 
-    public static final String IDENTIFIER = "tubemq";
+    public static final String IDENTIFIER = "tubemq-inlong";
 
     public static final List<String> INNERFORMATTYPE = Arrays.asList("inlong-msg");