Github user jackylk commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/1728#discussion_r158934363
  
    --- Diff: 
integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonPreAggregateRules.scala
 ---
    @@ -126,16 +127,17 @@ case class CarbonPreAggregateQueryRules(sparkSession: 
SparkSession) extends Rule
                 aggregateExp,
                 carbonTable,
                 tableName,
    -            list)
    -          carbonTable
    +            list,
    +            aggregateExpressions)
    +          (carbonTable, logicalRelation)
     
             // below case for handling filter query
             // When plan has grouping expression, aggregate expression
             // filter expression
             case Aggregate(groupingExp,
    -          aggregateExp,
    -          Filter(filterExp,
    -          CarbonSubqueryAlias(_, logicalRelation: LogicalRelation)))
    +        aggregateExp,
    --- End diff --
    
    unnecessary change


---

Reply via email to