Github user kunal642 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2501#discussion_r202903937
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/mutation/CarbonProjectForUpdateCommand.scala
---
@@ -59,6 +60,13 @@ private[sql] case class CarbonProjectForUpdateCommand(
return Seq.empty
}
val carbonTable = CarbonEnv.getCarbonTable(databaseNameOp,
tableName)(sparkSession)
+ columns.foreach { col =>
+ val dataType = carbonTable.getColumnByName(tableName,
col).getColumnSchema.getDataType
+ if (dataType.isComplexType) {
+ throw new MalformedCarbonCommandException("Unsupported operation
on Complex data type")
--- End diff --
throw UnsupportedOperationException
---
