Repository: kylin Updated Branches: refs/heads/yaho-cube-planner 52bec43d2 -> 0c4b3ad57
APACHE-KYLIN-2783: change the cuboid scheduler for FactDistinctColumnsMapper Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/e1256c89 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/e1256c89 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/e1256c89 Branch: refs/heads/yaho-cube-planner Commit: e1256c89c00a5d193a30c1464df0286e22471113 Parents: 52bec43 Author: Zhong <nju_y...@apache.org> Authored: Mon Aug 28 13:41:29 2017 +0800 Committer: Zhong <nju_y...@apache.org> Committed: Mon Aug 28 13:41:29 2017 +0800 ---------------------------------------------------------------------- .../apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/e1256c89/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java ---------------------------------------------------------------------- diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java index 16bc03c..4e4c332 100644 --- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java +++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java @@ -88,7 +88,7 @@ public class FactDistinctColumnsMapper<KEYIN> extends FactDistinctColumnsMapperB collectStatistics = Boolean.parseBoolean(context.getConfiguration().get(BatchConstants.CFG_STATISTICS_ENABLED)); if (collectStatistics) { samplingPercentage = Integer.parseInt(context.getConfiguration().get(BatchConstants.CFG_STATISTICS_SAMPLING_PERCENT)); - cuboidScheduler = cubeDesc.getInitialCuboidScheduler(); + cuboidScheduler = cubeSeg.getCuboidScheduler(); nRowKey = cubeDesc.getRowkey().getRowKeyColumns().length; List<Long> cuboidIdList = Lists.newArrayList();
