Github user kumarvishal09 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2195#discussion_r183057594
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/PreAggregateUtil.scala
---
@@ -438,7 +439,17 @@ object PreAggregateUtil {
wrapperTableInfo.getDataMapSchemaList.add(childSchema)
val thriftTable = schemaConverter.fromWrapperToExternalTableInfo(
wrapperTableInfo, dbName, tableName)
- updateSchemaInfo(carbonTable, thriftTable)(sparkSession)
+ try {
+ updateSchemaInfo(carbonTable, thriftTable)(sparkSession)
+ } catch {
+ case ex: Exception =>
+ val dropTableCommand =
CarbonDropDataMapCommand(childSchema.getDataMapName,
--- End diff --
Please add some comments
---
