Github user kumarvishal09 commented on a diff in the pull request: https://github.com/apache/carbondata/pull/1888#discussion_r165810950 --- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonPreAggregateRules.scala --- @@ -259,6 +259,7 @@ case class CarbonPreAggregateQueryRules(sparkSession: SparkSession) extends Rule * @return transformed plan */ def transformPreAggQueryPlan(logicalPlan: LogicalPlan): LogicalPlan = { + var isPlanUpdated = false --- End diff -- After applying pre aggregate rule we need to skip direct query on data map check
---