Github user jackylk commented on a diff in the pull request: https://github.com/apache/carbondata/pull/2083#discussion_r177145374 --- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonPreAggregateRules.scala --- @@ -349,10 +442,29 @@ case class CarbonPreAggregateQueryRules(sparkSession: SparkSession) extends Rule carbonTable, agg) isPlanUpdated = true - Aggregate(updatedGroupExp, + val updateAggPlan = Aggregate(updatedGroupExp, updatedAggExp, CarbonReflectionUtils .getSubqueryAlias(sparkSession, Some(alias), newChild, None)) + if(carbonTable.isStreamingTable) { --- End diff -- space after if
---