Github user ravipesala commented on a diff in the pull request: https://github.com/apache/carbondata/pull/1728#discussion_r159057341 --- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonPreAggregateRules.scala --- @@ -282,6 +136,7 @@ case class CarbonPreAggregateQueryRules(sparkSession: SparkSession) extends Rule val listFilterColumn = list .filter(queryColumn => queryColumn.getAggFunction.isEmpty && queryColumn.isFilterColumn) .toList + val isProjectionColumnPresent = (listProjectionColumn.size + listFilterColumn.size) > 0 // getting all the aggregation columns val listAggregationColumn = list.filter(queryColumn => !queryColumn.getAggFunction.isEmpty) --- End diff -- This code is unused now , please remove all code related to it.
---