Github user ravipesala commented on a diff in the pull request: https://github.com/apache/carbondata/pull/2148#discussion_r182636062 --- Diff: hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonInputFormat.java --- @@ -354,7 +365,9 @@ protected Expression getFilterPredicates(Configuration configuration) { DataMapJob dataMapJob = getDataMapJob(job.getConfiguration()); List<PartitionSpec> partitionsToPrune = getPartitionsToPrune(job.getConfiguration()); List<ExtendedBlocklet> prunedBlocklets; - if (distributedCG || dataMapExprWrapper.getDataMapType() == DataMapLevel.FG) { + if (isFgDataMapPruningEnable(job.getConfiguration()) && + (distributedCG || dataMapExprWrapper.getDataMapType() == DataMapLevel.FG) && + dataMapJob != null) { --- End diff -- But I guess we should prune with blockletdatamap once if fg is disabled.
---