From a28fd6fd8ebfaae3e6baa3b038889a96478a7559 Mon Sep 17 00:00:00 2001
From: vernedeng <vernedeng@apache.org>
Date: Thu, 21 Nov 2024 16:40:14 +0800
Subject: [PATCH] fix name

---
 .../apache/inlong/sort/base/dirty/sink/DirtyServerType.java   | 4 ++--
 .../tubemq/table/DynamicTubeMQTableDeserializationSchema.java | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/dirty/sink/DirtyServerType.java b/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/dirty/sink/DirtyServerType.java
index b75793af836..08f048b983c 100644
--- a/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/dirty/sink/DirtyServerType.java
+++ b/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/dirty/sink/DirtyServerType.java
@@ -20,10 +20,10 @@
 public enum DirtyServerType {
 
     UNDEFINED("Undefined"),
-    TUBE_MQ("TubeMQ"),
+    TUBEMQ("TubeMQ"),
     ICEBERG("Iceberg"),
     HIVE("Hive"),
-    STAR_ROCKS("StarRocks"),
+    STARROCKS("StarRocks"),
     KAFKA("Kafka"),
     PULSAR("Pulsar"),
     ELASTICSEARCH("Elasticsearch"),
diff --git a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/DynamicTubeMQTableDeserializationSchema.java b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/DynamicTubeMQTableDeserializationSchema.java
index 94631e7cd39..b5e63d072d0 100644
--- a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/DynamicTubeMQTableDeserializationSchema.java
+++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/DynamicTubeMQTableDeserializationSchema.java
@@ -144,7 +144,7 @@ public void deserialize(Message message, Collector<RowData> out) throws IOExcept
 
                         builder.setData(message.getData())
                                 .setDirtyType(DirtyType.KEY_DESERIALIZE_ERROR)
-                                .setServerType(DirtyServerType.TUBE_MQ)
+                                .setServerType(DirtyServerType.TUBEMQ)
                                 .setDirtyDataTime(dataTime)
                                 .setExtParams(message.getAttribute())
                                 .setLabels(dirtyOptions.getLabels())