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/da0a8e78 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/da0a8e78 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/da0a8e78 Branch: refs/heads/yaho-cube-planner Commit: da0a8e787a4de99539ab63b5989ff3db84fef091 Parents: 5b51fddc Author: Zhong <[email protected]> Authored: Mon Aug 28 13:41:29 2017 +0800 Committer: Zhong <[email protected]> Committed: Fri Sep 8 11:47:21 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/da0a8e78/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();
