This is an automated email from the ASF dual-hosted git repository.

ravipesala 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 61a5bd3  [HOTFIX] Fix dictionary include issue with codegen failure
61a5bd3 is described below

commit 61a5bd3351cfeaa85528abeb70a8eae9c6521db6
Author: ajantha-bhat <[email protected]>
AuthorDate: Fri Aug 9 17:33:34 2019 +0530

    [HOTFIX] Fix dictionary include issue with codegen failure
    
    problem: when whole codegen is false, query on dictionary include column 
fails.
    
    cause: This is because, the data type is not updated for dictionary include 
column.
    
    solution: return the updated expression when data type is changed for the 
dictionary include column
    
    This closes #3353
---
 .../scala/org/apache/spark/sql/optimizer/CarbonLateDecodeRule.scala  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/integration/spark2/src/main/scala/org/apache/spark/sql/optimizer/CarbonLateDecodeRule.scala
 
b/integration/spark2/src/main/scala/org/apache/spark/sql/optimizer/CarbonLateDecodeRule.scala
index 93773fc..961bf11 100644
--- 
a/integration/spark2/src/main/scala/org/apache/spark/sql/optimizer/CarbonLateDecodeRule.scala
+++ 
b/integration/spark2/src/main/scala/org/apache/spark/sql/optimizer/CarbonLateDecodeRule.scala
@@ -713,9 +713,10 @@ class CarbonLateDecodeRule extends Rule[LogicalPlan] with 
PredicateHelper {
             prExp.transform {
               case attr: AttributeReference =>
                 updateDataType(attr, attrMap, allAttrsNotDecode, aliasMap)
-            }
+            }.asInstanceOf[NamedExpression]
+          } else {
+            prExp
           }
-          prExp
         }
         Project(prExps, p.child)
       case wd: Window if relations.nonEmpty =>

Reply via email to