This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new 325847f66f2 branch-4.1: [fix](streaming-job) Encode CDC stream load
records as UTF-8 #66771 (#67034)
325847f66f2 is described below
commit 325847f66f22b0c3e70c0bc0d0a68e062f0b991d
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Aug 24 09:47:14 2026 +0800
branch-4.1: [fix](streaming-job) Encode CDC stream load records as UTF-8
#66771 (#67034)
Cherry-picked from #66771
Co-authored-by: wudi <[email protected]>
---
.../java/org/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 7e96a030df7..8f3de9fbf5c 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 class PipelineCoordinator {
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;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
