Repository: carbondata Updated Branches: refs/heads/master 580d4ec68 -> 84267dc7a
[HOTFIX] Use CG datamap to prune blocklet Correct incorrect variable when pruning with CG datamap Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/84267dc7 Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/84267dc7 Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/84267dc7 Branch: refs/heads/master Commit: 84267dc7ab3a12c800df0da13740c9f5afae0922 Parents: 580d4ec Author: Jacky Li <[email protected]> Authored: Mon Apr 23 22:57:43 2018 +0800 Committer: ravipesala <[email protected]> Committed: Tue Apr 24 14:45:34 2018 +0530 ---------------------------------------------------------------------- .../java/org/apache/carbondata/hadoop/api/CarbonInputFormat.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/carbondata/blob/84267dc7/hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonInputFormat.java ---------------------------------------------------------------------- diff --git a/hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonInputFormat.java b/hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonInputFormat.java index 38b46ea..5cca96c 100644 --- a/hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonInputFormat.java +++ b/hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonInputFormat.java @@ -424,10 +424,10 @@ public abstract class CarbonInputFormat<T> extends FileInputFormat<Void, T> { // Again prune with CG datamap. if (distributedCG && dataMapJob != null) { prunedBlocklets = - executeDataMapJob(carbonTable, resolver, segmentIds, dataMapExprWrapper, dataMapJob, + executeDataMapJob(carbonTable, resolver, segmentIds, cgDataMapExprWrapper, dataMapJob, partitionsToPrune); } else { - prunedBlocklets = dataMapExprWrapper.prune(segmentIds, partitionsToPrune); + prunedBlocklets = cgDataMapExprWrapper.prune(segmentIds, partitionsToPrune); } } // Now try to prune with FG DataMap.
