From 0abf9a7d661b8607b6a6fa058bd153f76d5c1c96 Mon Sep 17 00:00:00 2001
From: smallhibiscus <844981280>
Date: Wed, 31 Jan 2024 16:12:13 +0800
Subject: [PATCH] fix stream load's colunms can use keyword with sparksql

---
 .../main/java/org/apache/doris/spark/load/DorisStreamLoad.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java b/spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java
index 08bc29d1..ac74063e 100644
--- a/spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java
+++ b/spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java
@@ -31,6 +31,7 @@
 import org.apache.doris.spark.rest.RestService;
 import org.apache.doris.spark.rest.models.BackendV2;
 import org.apache.doris.spark.rest.models.RespContent;
+import org.apache.doris.spark.sql.Utils;
 import org.apache.doris.spark.util.ResponseUtil;
 import org.apache.http.HttpHeaders;
 import org.apache.http.HttpResponse;
@@ -180,7 +181,7 @@ private HttpPut getHttpPut(String label, String loadUrlStr, Boolean enable2PC, S
             httpPut.setHeader("columns", columns);
         } else {
             if (schema != null && !schema.isEmpty()) {
-                String dfColumns = Arrays.stream(schema.fieldNames()).collect(Collectors.joining(","));
+                String dfColumns = Arrays.stream(schema.fieldNames()).map(Utils::quote).collect(Collectors.joining(","));
                 httpPut.setHeader("columns", dfColumns);
             }
         }