From a3aa8e31eb72f19c15f8f2e419a19eadbc4c73af Mon Sep 17 00:00:00 2001
From: hffariel <farielclaire@gmail.com>
Date: Thu, 14 Oct 2021 21:48:44 +0800
Subject: [PATCH] optimize columns with backquotes

---
 .../starrockswriter/manager/StarRocksStreamLoadVisitor.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksStreamLoadVisitor.java b/starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksStreamLoadVisitor.java
index 656f4020..847635c8 100644
--- a/starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksStreamLoadVisitor.java
+++ b/starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksStreamLoadVisitor.java
@@ -26,6 +26,7 @@ import org.slf4j.LoggerFactory;
 
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
  
 public class StarRocksStreamLoadVisitor {
@@ -137,7 +138,7 @@ public class StarRocksStreamLoadVisitor {
             HttpPut httpPut = new HttpPut(loadUrl);
             List<String> cols = writerOptions.getColumns();
             if (null != cols && !cols.isEmpty()) {
-                httpPut.setHeader("columns", String.join(",", cols));
+                httpPut.setHeader("columns", String.join(",", cols.stream().map(f -> String.format("`%s`", f)).collect(Collectors.toList())));
             }
             if (null != writerOptions.getLoadProps()) {
                 for (Map.Entry<String, Object> entry : writerOptions.getLoadProps().entrySet()) {