[CARBONDATA-3467] Fix count(*) with filter on string column

apache · Jul 10, 2019 · a10d12a · a10d12a
1 parent 8f0ec97
commit a10d12a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/datamap/mv/core/src/main/scala/org/apache/carbondata/mv/datamap/MVAnalyzerRule.scala b/datamap/mv/core/src/main/scala/org/apache/carbondata/mv/datamap/MVAnalyzerRule.scala
@@ -70,7 +70,9 @@ class MVAnalyzerRule(sparkSession: SparkSession) extends Rule[LogicalPlan] {
     plan.transform {
       case aggregate@Aggregate(grp, aExp, child) =>
         // check for if plan is for dataload for preaggregate table, then skip applying mv
-        if (aExp.exists(p => p.name.equals("preAggLoad") || p.name.equals("preAgg"))) {
+        if (aExp.exists(p =>
+          !p.isInstanceOf[UnresolvedAlias] && (p.name.equals("preAggLoad") ||
+                                               p.name.equals("preAgg")))) {
           needAnalysis = false
         }
         Aggregate(grp, aExp, child)

diff --git a/datamap/mv/core/src/test/scala/org/apache/carbondata/mv/rewrite/TestAllOperationsOnMV.scala b/datamap/mv/core/src/test/scala/org/apache/carbondata/mv/rewrite/TestAllOperationsOnMV.scala
@@ -580,6 +580,6 @@ class TestAllOperationsOnMV extends QueryTest with BeforeAndAfterEach {
     newSet.addAll(oldSet)
     newSet
   }
-
+  
 }