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/74f581e7 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/74f581e7 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/74f581e7 Branch: refs/heads/yaho-cube-planner Commit: 74f581e78e491306d151545c78d717bf0bce79f8 Parents: 386a2ff Author: Zhong <nju_y...@apache.org> Authored: Mon Aug 28 13:41:29 2017 +0800 Committer: Zhong <nju_y...@apache.org> Committed: Fri Sep 8 11:33:04 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/74f581e7/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();
