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 11642df KYLIN-3457 use cube level config (#170) 11642df is described below commit 11642df257d514b68d23a1f85f093b8816b10967 Author: chao.long <wayn...@qq.com> AuthorDate: Thu Jul 19 16:43:37 2018 +0800 KYLIN-3457 use cube level config (#170) --- core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java b/core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java index 392323e..ea07835 100644 --- a/core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java +++ b/core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java @@ -270,7 +270,7 @@ public class JoinedFlatTable { } else if (flatDesc.getDistributedBy() != null) { appendDistributeStatement(sql, Lists.newArrayList(flatDesc.getDistributedBy())); } else { - int redistColumnCount = KylinConfig.getInstanceFromEnv().getHiveRedistributeColumnCount(); + int redistColumnCount = cubeDesc.getConfig().getHiveRedistributeColumnCount(); RowKeyColDesc[] rowKeyColDescs = cubeDesc.getRowkey().getRowKeyColumns();