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 e4442b6 fix filter in clause compilation (#277)
e4442b6 is described below
commit e4442b64066fbb3cad6c2ce17c26ab9acbf819e0
Author: gnehil <[email protected]>
AuthorDate: Mon Mar 10 11:19:47 2025 +0800
fix filter in clause compilation (#277)
---
.../src/main/scala/org/apache/doris/spark/util/DorisDialects.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/DorisDialects.scala
b/spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/DorisDialects.scala
index d761817..7329326 100644
---
a/spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/DorisDialects.scala
+++
b/spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/DorisDialects.scala
@@ -37,13 +37,13 @@ object DorisDialects {
if (values.isEmpty || values.length >= inValueLengthLimit) {
null
} else {
- s"${quote(attribute)} IN (${compileValue(values)})"
+ s"${quote(attribute)} IN
${values.map(compileValue).mkString("(",",",")")}"
}
case Not(In(attribute, values)) =>
if (values.isEmpty || values.length >= inValueLengthLimit) {
null
} else {
- s"${quote(attribute)} NOT IN (${compileValue(values)})"
+ s"${quote(attribute)} NOT IN
${values.map(compileValue).mkString("(",",",")")}"
}
case IsNull(attribute) => s"${quote(attribute)} IS NULL"
case IsNotNull(attribute) => s"${quote(attribute)} IS NOT NULL"
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
