This is an automated email from the ASF dual-hosted git repository. shaofengshi pushed a commit to branch 2.5.x in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/2.5.x by this push: new e5631d2 use cube config when uhc step enabled e5631d2 is described below commit e5631d28968d32199dad2130237d4513262c392c Author: Changji Guo <35126911+changji...@users.noreply.github.com> AuthorDate: Wed Mar 25 20:33:43 2020 +0800 use cube config when uhc step enabled --- .../java/org/apache/kylin/engine/mr/steps/CreateDictionaryJob.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/CreateDictionaryJob.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/CreateDictionaryJob.java index aeb7b12..275967f 100644 --- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/CreateDictionaryJob.java +++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/CreateDictionaryJob.java @@ -82,9 +82,9 @@ public class CreateDictionaryJob extends AbstractHadoopJob { CubeManager cubeManager = CubeManager.getInstance(config); CubeInstance cube = cubeManager.getCube(cubeName); List<TblColRef> uhcColumns = cube.getDescriptor().getAllUHCColumns(); - + KylinConfig cubeConfig = cube.getConfig(); Path colDir; - if (config.isBuildUHCDictWithMREnabled() && uhcColumns.contains(col)) { + if (cubeConfig.isBuildUHCDictWithMREnabled() && uhcColumns.contains(col)) { colDir = new Path(dictPath, col.getIdentity()); } else { colDir = new Path(factColumnsInputPath, col.getIdentity());