From 88c1d7824b7c2f8ee3c0b363616feba7b14ee1ac Mon Sep 17 00:00:00 2001 From: Zhong Date: Wed, 21 Mar 2018 18:04:43 +0800 Subject: [PATCH] APACHE-KYLIN-3018: minor fix --- .../main/java/org/apache/kylin/engine/spark/SparkCubingByLayer.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkCubingByLayer.java b/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkCubingByLayer.java index 0d26815..714991d 100644 --- a/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkCubingByLayer.java +++ b/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkCubingByLayer.java @@ -45,7 +45,6 @@ import org.apache.kylin.cube.CubeSegment; import org.apache.kylin.cube.common.RowKeySplitter; import org.apache.kylin.cube.cuboid.Cuboid; import org.apache.kylin.cube.cuboid.CuboidScheduler; -import org.apache.kylin.cube.cuboid.CuboidUtil; import org.apache.kylin.cube.kv.AbstractRowKeyEncoder; import org.apache.kylin.cube.kv.RowKeyEncoderProvider; import org.apache.kylin.cube.model.CubeDesc; @@ -184,7 +183,7 @@ public class SparkCubingByLayer extends AbstractApplication implements Serializa reducerFunction2 = new CuboidReducerFunction2(cubeName, metaUrl, sConf, needAggr); } - final int totalLevels = CuboidUtil.getLongestDepth(cubeSegment.getCuboidScheduler().getAllCuboidIds()); + final int totalLevels = cubeSegment.getCuboidScheduler().getBuildLevel(); JavaPairRDD[] allRDDs = new JavaPairRDD[totalLevels + 1]; int level = 0; int partition = estimateRDDPartitionNum(level, cubeStatsReader, envConfig); -- 2.5.4 (Apple Git-61)