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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
