Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2148#discussion_r182643983
--- 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 --
I changed the condition again, please check
---
