You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2017/09/10 05:29:19 UTC
[16/28] kylin git commit: minor, fix NPE
minor, fix NPE
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/8edc901d
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/8edc901d
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/8edc901d
Branch: refs/heads/master
Commit: 8edc901dec945776c7989c414a4eee746a5f741a
Parents: b1559c6
Author: Cheng Wang <ch...@kyligence.io>
Authored: Wed Sep 6 19:28:12 2017 +0800
Committer: Dong Li <li...@apache.org>
Committed: Wed Sep 6 19:30:15 2017 +0800
----------------------------------------------------------------------
.../org/apache/kylin/engine/spark/SparkBatchCubingJobBuilder2.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/8edc901d/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkBatchCubingJobBuilder2.java
----------------------------------------------------------------------
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 2773f97..27bcff3 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
@@ -52,6 +52,7 @@ public class SparkBatchCubingJobBuilder2 extends BatchCubingJobBuilder2 {
sparkExecutable.setParam(SparkCubingByLayer.OPTION_META_URL.getOpt(),
getSegmentMetadataUrl(seg.getConfig(), seg.getUuid()));
sparkExecutable.setParam(SparkCubingByLayer.OPTION_OUTPUT_PATH.getOpt(), cuboidRootPath);
+ sparkExecutable.setJobId(jobId);
StringBuilder jars = new StringBuilder();