Github user xuchuanyin commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2851#discussion_r228009613
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/events/MergeBloomIndexEventListener.scala
---
@@ -48,8 +48,14 @@ class MergeBloomIndexEventListener extends
OperationEventListener with Logging {
_.getDataMapSchema.getProviderName.equalsIgnoreCase(
DataMapClassProvider.BLOOMFILTER.getShortName))
- // for load process, filter lazy datamap
- if (!datamapPostEvent.isFromRebuild) {
+ if (datamapPostEvent.isFromRebuild) {
+ if (null != datamapPostEvent.dmName) {
+ // for rebuild process, event will be called for each datamap
--- End diff --
'for each datamap' or 'only for specific datamap'?
---
