This is an automated email from the ASF dual-hosted git repository. shaofengshi pushed a commit to branch 3.0.x in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/3.0.x by this push: new 25ce513 use cube config when uhc step enabled 25ce513 is described below commit 25ce5137923aa5be29f5f735f96dc285e6025de0 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 6ab4976..dc057bb 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());