Github user praveenmeenakshi56 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2552#discussion_r206521693
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/datamap/CarbonCreateDataMapCommand.scala
---
@@ -181,7 +181,18 @@ case class CarbonCreateDataMapCommand(
override def undoMetadata(sparkSession: SparkSession, exception:
Exception): Seq[Row] = {
if (dataMapProvider != null) {
- dataMapProvider.cleanMeta()
+ if (dataMapSchema.getProviderName
--- End diff --
We need this check because we want the implementation of cleanMeta() method
in PreAggregregateDataMapProvider. For others, It will take from
IndexDataMapProvider
---
