[INLONG-11473][SORT] Fix AUDIT_DATA_TIME not removed when sink to Sta…

…rRocks
apache · Nov 8, 2024 · 2c0f63f · 2c0f63f
1 parent 99dec05
commit 2c0f63f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ava/org/apache/inlong/sort/starrocks/table/sink/table/StarRocksDynamicSinkFunctionV2.java b/...ava/org/apache/inlong/sort/starrocks/table/sink/table/StarRocksDynamicSinkFunctionV2.java
@@ -214,7 +214,7 @@ public void invoke(T value, Context context)
         long serializeStartTime = System.currentTimeMillis();
         String serializedData;
         try {
-            serializedData = serializer.serialize(data);
+            serializedData = serializer.serialize(schemaUtils.filterOutTimeField(data));
         } catch (Exception e) {
             log.error("Failed to serialize data", e);
             if (sinkExactlyMetric != null) {