Github user xuchuanyin commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2405#discussion_r198123518
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/datamap/CarbonCreateDataMapCommand.scala
---
@@ -99,17 +97,22 @@ case class CarbonCreateDataMapCommand(
dataMapProvider match {
case provider: IndexDataMapProvider =>
val datamaps =
DataMapStoreManager.getInstance.getAllDataMap(mainTable).asScala
- val existingIndexColumn = mutable.Set[String]()
- datamaps.foreach { datamap =>
-
datamap.getDataMapSchema.getIndexColumns.foreach(existingIndexColumn.add)
+ val existingIndexColumn4ThisProvider = mutable.Set[String]()
+ val thisDmProviderName =
+
dataMapProvider.asInstanceOf[IndexDataMapProvider].getDataMapSchema.getProviderName
+ datamaps.filter(datamap => thisDmProviderName.equalsIgnoreCase(
+ datamap.getDataMapSchema.getProviderName)).foreach { datamap =>
--- End diff --
fixed~
---
