You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ra...@apache.org on 2018/04/24 09:15:50 UTC
carbondata git commit: [HOTFIX] Use CG datamap to prune blocklet
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 <ja...@huawei.com>
Authored: Mon Apr 23 22:57:43 2018 +0800
Committer: ravipesala <ra...@gmail.com>
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.