carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kunalkap...@apache.org
Subject [carbondata] branch master updated: [CARBONDATA-3502] Select query with UDF having Match expression inside IN expression Fails
Date Thu, 05 Sep 2019 08:37:45 GMT
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 <manish.nalla1994@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, _, _) =>


Mime
View raw message