fix

apache · Nov 22, 2024 · efb5962 · efb5962
1 parent 26f3b75
commit efb5962
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ink/base/src/main/java/org/apache/inlong/sort/base/dirty/sink/sdk/InlongSdkDirtySink.java b/...ink/base/src/main/java/org/apache/inlong/sort/base/dirty/sink/sdk/InlongSdkDirtySink.java
@@ -67,7 +67,7 @@ public void invoke(DirtyData<T> dirtyData) throws Exception {
                     .inlongStreamId(dataStreamId)
                     .dataflowId(dataflowId)
                     .dataTime(dirtyData.getDataTime())
-                    .serverType(dirtyData.getServerType().format())
+                    .serverType(dirtyData.getServerType())
                     .dirtyType(dirtyData.getDirtyType().format())
                     .dirtyMessage(dirtyData.getDirtyMessage())
                     .ext(dirtyData.getExtParams())