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());

Reply via email to