This is an automated email from the ASF dual-hosted git repository.

shaofengshi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/master by this push:
     new 87bc875  use cube config when uhc step enabled
87bc875 is described below

commit 87bc875df495e5bad3b58f45b99a2781d4e0b4ac
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());

Reply via email to