Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1665#discussion_r157356143
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/parser/CarbonSparkSqlParser.scala
---
@@ -210,13 +211,40 @@ class CarbonHelperSqlAstBuilder(conf: SQLConf,
parser: CarbonSpark2SqlParser)
}
}
- val fields = parser.getFields(cols ++ partitionByStructFields)
+ var fields = parser.getFields(cols ++ partitionByStructFields)
val options = new CarbonOption(properties)
// validate tblProperties
val bucketFields = parser.getBucketFields(tableProperties, fields,
options)
validateStreamingProperty(options)
+ // validate for create table as select
--- End diff --
move this logic to a validateSelectQueryForCTAS function
---
