(inlong) branch master updated: [INLONG-11473][SORT] Fix AUDIT_DATA_TIME not removed when sink to StarRocks (#11474)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 87d0a92995 [INLONG-11473][SORT] Fix AUDIT_DATA_TIME not removed when 
sink to StarRocks (#11474)
87d0a92995 is described below

commit 87d0a9299517ff1fe32a4d8f8c6eaceb60580802
Author: vernedeng <verned...@apache.org>
AuthorDate: Mon Nov 11 10:42:02 2024 +0800

    [INLONG-11473][SORT] Fix AUDIT_DATA_TIME not removed when sink to StarRocks 
(#11474)
---
 .../sort/starrocks/table/sink/table/StarRocksDynamicSinkFunctionV2.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/table/sink/table/StarRocksDynamicSinkFunctionV2.java
 
b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/table/sink/table/StarRocksDynamicSinkFunctionV2.java
index a829ed26b7..38076709a8 100644
--- 
a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/table/sink/table/StarRocksDynamicSinkFunctionV2.java
+++ 
b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/table/sink/table/StarRocksDynamicSinkFunctionV2.java
@@ -214,7 +214,7 @@ public class StarRocksDynamicSinkFunctionV2<T> extends 
StarRocksDynamicSinkFunct
         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) {