Github user jackylk commented on a diff in the pull request: https://github.com/apache/carbondata/pull/1694#discussion_r158931327 --- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/PreAggregateUtil.scala --- @@ -126,19 +126,33 @@ object PreAggregateUtil { attr.aggregateFunction, parentTableName, parentDatabaseName, - parentTableId) + parentTableId, + "column_" + counter) + counter = counter + 1 case attr: AttributeReference => + val columnRelation = getColumnRelation(attr.name, + parentTableId, + parentTableName, + parentDatabaseName, + carbonTable) + val arrayBuffer = new ArrayBuffer[ColumnTableRelation]() + arrayBuffer += columnRelation fieldToDataMapFieldMap += getField(attr.name, attr.dataType, - parentColumnId = carbonTable.getColumnByName(parentTableName, attr.name).getColumnId, parentTableName = parentTableName, - parentDatabaseName = parentDatabaseName, parentTableId = parentTableId) + columnTableRelationList = arrayBuffer.toList) case Alias(attr: AttributeReference, _) => + val columnRelation = getColumnRelation(attr.name, --- End diff -- move `attr.name` to next line, do the same for all place in this function
---