You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by wy...@apache.org on 2022/02/13 08:50:32 UTC
[incubator-doris-connectors] branch master updated: [Bug-Fix][Spark-Doris-Connector] resolve the problem of writing Chinese garbled characters (#6)
This is an automated email from the ASF dual-hosted git repository.
wyf pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris-connectors.git
The following commit(s) were added to refs/heads/master by this push:
new afb45af [Bug-Fix][Spark-Doris-Connector] resolve the problem of writing Chinese garbled characters (#6)
afb45af is described below
commit afb45af0392d03d1894f10dc0f7959c6f646832f
Author: jiafeng.zhang <zh...@gmail.com>
AuthorDate: Sun Feb 13 16:50:29 2022 +0800
[Bug-Fix][Spark-Doris-Connector] resolve the problem of writing Chinese garbled characters (#6)
resolve the problem of writing Chinese garbled characters
---
.../src/main/java/org/apache/doris/spark/DorisStreamLoad.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/spark-doris-connector/src/main/java/org/apache/doris/spark/DorisStreamLoad.java b/spark-doris-connector/src/main/java/org/apache/doris/spark/DorisStreamLoad.java
index ec3892d..b74e0a8 100644
--- a/spark-doris-connector/src/main/java/org/apache/doris/spark/DorisStreamLoad.java
+++ b/spark-doris-connector/src/main/java/org/apache/doris/spark/DorisStreamLoad.java
@@ -193,7 +193,7 @@ public class DorisStreamLoad implements Serializable{
beConn = getConnection(loadUrlStr, label);
// send data to be
BufferedOutputStream bos = new BufferedOutputStream(beConn.getOutputStream());
- bos.write(value.getBytes());
+ bos.write(value.getBytes("UTF-8"));
bos.close();
// get respond
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org