Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2083#discussion_r177683347
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonPreAggregateRules.scala
---
@@ -262,12 +351,12 @@ case class CarbonPreAggregateQueryRules(sparkSession:
SparkSession) extends Rule
var isPlanUpdated = false
val updatedPlan = logicalPlan.transform {
case agg@Aggregate(
- grExp,
- aggExp,
- CarbonSubqueryAlias(alias1, child@CarbonSubqueryAlias(alias2, l:
LogicalRelation)))
+ grExp,
+ aggExp,
+ CarbonSubqueryAlias(alias1, child@CarbonSubqueryAlias(alias2, l:
LogicalRelation)))
--- End diff --
Format it properly
---
