Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1508#discussion_r153722623
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/CreatePreAggregateTableCommand.scala
---
@@ -94,10 +95,21 @@ case class CreatePreAggregateTableCommand(
dmproperties.foreach(f => childSchema.getProperties.put(f._1, f._2))
// updating the parent table about child table
PreAggregateUtil.updateMainTable(parentDbName, parentTableName,
childSchema, sparkSession)
- val loadAvailable = PreAggregateUtil.checkMainTableLoad(parentTable)
- if (loadAvailable) {
- sparkSession.sql(
- s"insert into ${ tableModel.databaseName }.${
tableModel.tableName } $queryString")
+ val availableLoads = PreAggregateUtil.checkMainTableLoad(parentTable)
+ if (availableLoads) {
+ val headers =
childSchema.getChildSchema.getListOfColumns.asScala.map(_.getColumnName)
--- End diff --
Move line done
---
