fix name

vernedeng · Nov 21, 2024 · a28fd6f · a28fd6f
1 parent f752551
commit a28fd6f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...sort-flink/base/src/main/java/org/apache/inlong/sort/base/dirty/sink/DirtyServerType.java b/...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/...ain/java/org/apache/inlong/sort/tubemq/table/DynamicTubeMQTableDeserializationSchema.java b/...ain/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())