You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by di...@apache.org on 2023/11/09 13:23:16 UTC

(doris-spark-connector) branch master updated: [Fix] quote field name with grave accent (#158)

This is an automated email from the ASF dual-hosted git repository.

diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-spark-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new de60f63  [Fix] quote field name with grave accent (#158)
de60f63 is described below

commit de60f635cee7f30512d11126022402226641fc74
Author: gnehil <ad...@gmail.com>
AuthorDate: Thu Nov 9 21:23:11 2023 +0800

    [Fix] quote field name with grave accent (#158)
    
    Co-authored-by: gnehil <gn...@github>
---
 .../src/main/scala/org/apache/doris/spark/sql/DorisRelation.scala       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisRelation.scala b/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisRelation.scala
index fe7e63d..db546ce 100644
--- a/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisRelation.scala
+++ b/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisRelation.scala
@@ -76,7 +76,7 @@ private[sql] class DorisRelation(
           requiredColumns.map(Utils.quote).mkString(","))
     } else {
       paramWithScan += (ConfigurationOptions.DORIS_READ_FIELD ->
-          lazySchema.fields.map(f => f.name).mkString(","))
+          lazySchema.fields.map(f => Utils.quote(f.name)).mkString(","))
     }
 
     if (filters != null && filters.length > 0) {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org