You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ku...@apache.org on 2019/09/05 08:37:45 UTC
[carbondata] branch master updated: [CARBONDATA-3502] Select query
with UDF having Match expression inside IN expression Fails
This is an automated email from the ASF dual-hosted git repository.
kunalkapoor pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/carbondata.git
The following commit(s) were added to refs/heads/master by this push:
new 57e4e9e [CARBONDATA-3502] Select query with UDF having Match expression inside IN expression Fails
57e4e9e is described below
commit 57e4e9e9c12adabfe83b8c69a70523f8c9bdeb72
Author: manishnalla1994 <ma...@gmail.com>
AuthorDate: Mon Aug 26 17:25:34 2019 +0530
[CARBONDATA-3502] Select query with UDF having Match expression
inside IN expression Fails
Problem: Select query with UDF having Match expression inside
IN expression Fails with ArrayIndexOutOfBounds exception.
Cause: The expression should not be treated as Match expression,
instead should be treated as SparkUnknownExpression.
Solution: Removed the check for Match Expression as it was only added
for Lucene Search mode, which is no longer present.
This closes #3363
---
.../src/main/scala/org/apache/spark/sql/optimizer/CarbonFilters.scala | 2 --
1 file changed, 2 deletions(-)
diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/optimizer/CarbonFilters.scala b/integration/spark2/src/main/scala/org/apache/spark/sql/optimizer/CarbonFilters.scala
index c4415f8..0fd07bb 100644
--- a/integration/spark2/src/main/scala/org/apache/spark/sql/optimizer/CarbonFilters.scala
+++ b/integration/spark2/src/main/scala/org/apache/spark/sql/optimizer/CarbonFilters.scala
@@ -425,8 +425,6 @@ object CarbonFilters {
new AndExpression(l, r)
case strTrim: StringTrim if isStringTrimCompatibleWithCarbon(strTrim) =>
transformExpression(strTrim)
- case s: ScalaUDF =>
- new MatchExpression(s.children.head.toString())
case _ =>
new SparkUnknownExpression(expr.transform {
case AttributeReference(name, dataType, _, _) =>