Github user kunal642 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2390#discussion_r197029663
--- Diff:
integration/spark-common/src/main/scala/org/apache/spark/sql/catalyst/CarbonDDLSqlParser.scala
---
@@ -444,16 +481,29 @@ abstract class CarbonDDLSqlParser extends
AbstractCarbonSparkSQLParser {
throw new MalformedCarbonCommandException(errormsg)
}
}
+
+ // Validate whether any of the child columns of complex dataType
column is a string column
+ localDictColumns.foreach { dictColm =>
+ if (fields
+ .exists(x => x.column.equalsIgnoreCase(dictColm) &&
x.children.isDefined &&
+ null != x.children.get &&
+ !validateChildColumns(x))) {
+ val errMsg = "Child columns do not exist for the specified complex
dataType column(s) in local_dictionary_include."
--- End diff --
Throw proper error message.
---
