Github user jackylk commented on a diff in the pull request: https://github.com/apache/carbondata/pull/1888#discussion_r165809302 --- 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 -- why this is required
---