From 4766080294575f8194bf5344702045d9f7962d06 Mon Sep 17 00:00:00 2001
From: wudi <wudi@selectdb.com>
Date: Fri, 14 Aug 2026 14:48:23 +0800
Subject: [PATCH] [fix](streaming-job) Encode CDC stream load records as UTF-8

---
 .../apache/doris/cdcclient/service/PipelineCoordinator.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/service/PipelineCoordinator.java b/fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/service/PipelineCoordinator.java
index 7e96a030df7d04..8f3de9fbf5c1f3 100644
--- a/fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/service/PipelineCoordinator.java
+++ b/fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/service/PipelineCoordinator.java
@@ -621,7 +621,8 @@ public void writeRecords(WriteRecordRequest writeRecordRequest) throws Exception
                         String dorisTable = targetTableMappings.getOrDefault(table, table);
                         for (String record : result.getRecords()) {
                             scannedRows++;
-                            batchStreamLoad.writeRecord(targetDb, dorisTable, record.getBytes());
+                            batchStreamLoad.writeRecord(
+                                    targetDb, dorisTable, record.getBytes(StandardCharsets.UTF_8));
                         }
                         // Mark last message as data (not heartbeat)
                         lastMessageIsHeartbeat = false;