Github user xuchuanyin commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2491#discussion_r202000213
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/datamap/CarbonCreateDataMapCommand.scala
---
@@ -109,6 +111,19 @@ case class CarbonCreateDataMapCommand(
throw new MalformedDataMapCommandException(String.format(
"column '%s' already has %s index datamap created",
column.getColName, thisDmProviderName))
+ } else if (isBloomFilter) {
+ // if datamap provider is bloomfilter,the index column
datatype cannot be complex type
+ if (column.isComplex) {
+ throw new MalformedDataMapCommandException(String.format(
+ "since datamap provider is bloomfilter , the index column
'%s' datatype cannot be" +
--- End diff --
optimize the message format like "BloomFilter datamap does not support
complex datatype column: ${column.getColName}"
The same for the below if branch
---
