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

Reply via email to