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