KYLIN-2434 minor fix
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/eee9ecbc Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/eee9ecbc Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/eee9ecbc Branch: refs/heads/KYLIN-2428 Commit: eee9ecbcb031862ed316f630933bb320cf93a9d1 Parents: f62465c Author: lidongsjtu <lid...@apache.org> Authored: Tue Feb 7 17:37:21 2017 +0800 Committer: lidongsjtu <lid...@apache.org> Committed: Tue Feb 7 17:37:21 2017 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/engine/spark/SparkCubingByLayer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/eee9ecbc/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkCubingByLayer.java ---------------------------------------------------------------------- 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 071806c..317d2bd 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 @@ -150,12 +150,12 @@ public class SparkCubingByLayer extends AbstractApplication implements Serializa setupClasspath(sc, confPath); HadoopUtil.deletePath(sc.hadoopConfiguration(), new Path(outputPath)); + System.setProperty(KylinConfig.KYLIN_CONF, confPath); final KylinConfig envConfig = KylinConfig.getInstanceFromEnv(); HiveContext sqlContext = new HiveContext(sc.sc()); final DataFrame intermediateTable = sqlContext.table(envConfig.getHiveDatabaseForIntermediateTable() + "." + hiveTable); - System.setProperty(KylinConfig.KYLIN_CONF, confPath); final CubeInstance cubeInstance = CubeManager.getInstance(envConfig).getCube(cubeName); final CubeDesc cubeDesc = cubeInstance.getDescriptor(); final CubeSegment cubeSegment = cubeInstance.getSegmentById(segmentId);
