Github user xuchuanyin commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2255#discussion_r186294368
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonInputFormat.java ---
@@ -447,18 +450,22 @@ protected Expression
getFilterPredicates(Configuration configuration) {
cgDataMapExprWrapper.getDataMapSchema(), prunedBlocklets.size());
}
// Now try to prune with FG DataMap.
- dataMapExprWrapper = DataMapChooser.get()
+ DataMapExprWrapper fgDataMapExprWrapper = DataMapChooser.get()
.chooseFGDataMap(getOrCreateCarbonTable(job.getConfiguration()),
resolver);
- if (dataMapExprWrapper != null && dataMapExprWrapper.getDataMapLevel()
== DataMapLevel.FG
- && isFgDataMapPruningEnable(job.getConfiguration()) && dataMapJob
!= null) {
+ if (fgDataMapExprWrapper != null &&
--- End diff --
Same as Line435
---
