From 23078a5cee4f0e30cff3ff6100724b921c8ea46c Mon Sep 17 00:00:00 2001
From: Youngwb <yangwenbo_mailbox@163.com>
Date: Mon, 18 Nov 2019 21:14:35 +0800
Subject: [PATCH] Avoid Chinese garbled for streamLoad java sample (#2229)

---
 samples/stream_load/java/DorisStreamLoad.java | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/samples/stream_load/java/DorisStreamLoad.java b/samples/stream_load/java/DorisStreamLoad.java
index bbc15ef2fa..fbf9b8c96d 100644
--- a/samples/stream_load/java/DorisStreamLoad.java
+++ b/samples/stream_load/java/DorisStreamLoad.java
@@ -45,7 +45,8 @@ import java.nio.charset.StandardCharsets;
  *
  * CREATE TABLE `stream_test` (
  *   `id` bigint(20) COMMENT "",
- *   `id2` bigint(20) COMMENT ""
+ *   `id2` bigint(20) COMMENT "",
+ *   `username` varchar(32) COMMENT ""
  * ) ENGINE=OLAP
  * DUPLICATE KEY(`id`)
  * DISTRIBUTED BY HASH(`id`) BUCKETS 20;
@@ -122,12 +123,12 @@ public class DorisStreamLoad {
 
         try (CloseableHttpClient client = httpClientBuilder.build()) {
             HttpPut put = new HttpPut(loadUrl);
-            StringEntity entity = new StringEntity(content);
+            StringEntity entity = new StringEntity(content, "UTF-8");
             put.setHeader(HttpHeaders.EXPECT, "100-continue");
             put.setHeader(HttpHeaders.AUTHORIZATION, basicAuthHeader(DORIS_USER, DORIS_PASSWORD));
             // the label header is optional, not necessary
             // use label header can ensure at most once semantics
-            put.setHeader("label", "39c25a5c-7000-496e-a98e-348a264c81de")
+            put.setHeader("label", "39c25a5c-7000-496e-a98e-348a264c81de");
             put.setEntity(entity);
 
             try (CloseableHttpResponse response = client.execute(put)) {
@@ -155,8 +156,9 @@ public class DorisStreamLoad {
     public static void main(String[] args) throws Exception {
         int id1 = 1;
         int id2 = 10;
+        String id3 = "张三";
         int rowNumber = 10;
-        String oneRow = id1 + "\t" + id2 + "\n";
+        String oneRow = id1 + "\t" + id2 + "\t" + id3 + "\n";
 
         StringBuilder stringBuilder = new StringBuilder();
         for (int i = 0; i < rowNumber; i++) {