Github user xubo245 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2148#discussion_r182689498
--- 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 --
The logical was changed, should be
` if (dataMapJob != null &&
(distributedCG ||
isFgDataMapPruningEnable(job.getConfiguration()) && dataMapLevel ==
DataMapLevel.FG)) `
---
