Github user xuchuanyin commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2379#discussion_r196635418
--- Diff:
integration/spark-common/src/main/scala/org/apache/spark/sql/catalyst/CarbonDDLSqlParser.scala
---
@@ -279,7 +279,7 @@ abstract class CarbonDDLSqlParser extends
AbstractCarbonSparkSQLParser {
fields.zipWithIndex.foreach { case (field, index) =>
field.schemaOrdinal = index
}
- val (dims, msrs, noDictionaryDims, sortKeyDims) =
extractDimAndMsrFields(
+ val (dims, msrs, noDictionaryDims, sortKeyDims, varcharColumns) =
extractDimAndMsrFields(
--- End diff --
Just like the other results of `extractDimAndMsrFields`, we validate and
get the sort_column, dictionaries and the varcharColumns(longStringColumns).
For the varcharColumns, we change their datatype from string to varchar
later.
---
