This is an automated email from the ASF dual-hosted git repository. xxyu pushed a commit to branch 2.6.x in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/2.6.x by this push: new bf39e03 KYLIN-4882 config["kylin.engine.spark-fact-distinct"] overwrite in the Cube-level is invalid bf39e03 is described below commit bf39e03939b34e6faf2ce88e6b362c808636107a Author: ITzhangqiang <itzhangqi...@163.com> AuthorDate: Fri Jan 22 10:22:35 2021 +0800 KYLIN-4882 config["kylin.engine.spark-fact-distinct"] overwrite in the Cube-level is invalid --- .../org/apache/kylin/engine/spark/SparkBatchCubingJobBuilder2.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkBatchCubingJobBuilder2.java b/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkBatchCubingJobBuilder2.java index e0c6eee..6d55d17 100644 --- a/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkBatchCubingJobBuilder2.java +++ b/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkBatchCubingJobBuilder2.java @@ -65,8 +65,7 @@ public class SparkBatchCubingJobBuilder2 extends JobBuilderSupport { inputSide.addStepPhase1_CreateFlatTable(result); // Phase 2: Build Dictionary - KylinConfig config = KylinConfig.getInstanceFromEnv(); - if (config.isSparkFactDistinctEnable()) { + if (seg.getConfig().isSparkFactDistinctEnable()) { result.addTask(createFactDistinctColumnsSparkStep(jobId)); } else { result.addTask(createFactDistinctColumnsStep(jobId));