Github user mohammadshahidkhan commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2389#discussion_r197025960
--- Diff:
integration/spark2/src/main/scala/org/apache/carbondata/spark/rdd/CarbonTableCompactor.scala
---
@@ -272,6 +284,13 @@ class CarbonTableCompactor(carbonLoadModel:
CarbonLoadModel,
mergedLoadName)
OperationListenerBus.getInstance()
.fireEvent(compactionLoadStatusPostEvent, operationContext)
+ if (null != tableDataMaps) {
+ val buildDataMapPostExecutionEvent: BuildDataMapPostExecutionEvent
=
+ new BuildDataMapPostExecutionEvent(sqlContext.sparkSession,
--- End diff --
Changed to BuildDataMapPreExecutionEvent
---