Github user jackylk commented on a diff in the pull request: https://github.com/apache/carbondata/pull/2148#discussion_r182778652 --- Diff: hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonInputFormat.java --- @@ -365,9 +365,10 @@ protected Expression getFilterPredicates(Configuration configuration) { DataMapJob dataMapJob = getDataMapJob(job.getConfiguration()); List<PartitionSpec> partitionsToPrune = getPartitionsToPrune(job.getConfiguration()); List<ExtendedBlocklet> prunedBlocklets; - if (isFgDataMapPruningEnable(job.getConfiguration()) && - (distributedCG || dataMapExprWrapper.getDataMapType() == DataMapLevel.FG) && - dataMapJob != null) { + DataMapLevel dataMapLevel = dataMapExprWrapper.getDataMapType(); + if (dataMapJob != null && + distributedCG || --- End diff -- fixed
---