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 <[email protected]>
AuthorDate: Thu Nov 9 21:23:11 2023 +0800
[Fix] quote field name with grave accent (#158)
Co-authored-by: gnehil <gnehil489@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: [email protected]
For additional commands, e-mail: [email protected]
