Github user chenliang613 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1575#discussion_r158056650
--- Diff:
integration/spark2/src/main/scala/org/apache/carbondata/spark/rdd/CarbonDataRDDFactory.scala
---
@@ -205,7 +205,8 @@ object CarbonDataRDDFactory {
val newCarbonLoadModel = prepareCarbonLoadModel(table)
- val compactionSize =
CarbonDataMergerUtil.getCompactionSize(CompactionType.MAJOR)
+ val compactionSize = CarbonDataMergerUtil
+ .getCompactionSize(CompactionType.MAJOR, carbonLoadModel)
--- End diff --
why need add one more input parameter(carbonLoadModel) for
getCompactionSize()?
---
