Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1626#discussion_r155276144
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/PreAggregateListeners.scala
---
@@ -65,6 +95,10 @@ object LoadPostAggregateListener extends
OperationEventListener {
dataFrame = Some(childDataFrame),
internalOptions =
Map(CarbonCommonConstants.IS_INTERNAL_LOAD_CALL -> "true")).
run(sparkSession)
+ if (dataMapSchema.isInstanceOf[AggregationDataMapSchema] &&
--- End diff --
remove this check
---