From b62b32d2a2c67f77a176d776c1c3df3af1e3faa6 Mon Sep 17 00:00:00 2001
From: vernedeng <vernedeng@apache.org>
Date: Thu, 19 Oct 2023 18:32:16 +0800
Subject: [PATCH] [INLONG-9075][Sort] TubeMQSource support InlongMsg format

---
 .../inlong/sort/tubemq/table/TubeMQDynamicTableFactory.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQDynamicTableFactory.java b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQDynamicTableFactory.java
index 17275d8d113..3110392a386 100644
--- a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQDynamicTableFactory.java
+++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/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");