You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by qh...@apache.org on 2015/06/15 15:00:29 UTC
incubator-kylin git commit: exit immediately once the
OneOffStreamBuilder finished
Repository: incubator-kylin
Updated Branches:
refs/heads/0.8 60662820e -> c48962de3
exit immediately once the OneOffStreamBuilder finished
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/c48962de
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/c48962de
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/c48962de
Branch: refs/heads/0.8
Commit: c48962de3ad0234d5ca370660ed20188343ebd89
Parents: 6066282
Author: qianhao.zhou <qi...@ebay.com>
Authored: Mon Jun 15 21:00:14 2015 +0800
Committer: qianhao.zhou <qi...@ebay.com>
Committed: Mon Jun 15 21:00:14 2015 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/job/streaming/StreamingBootstrap.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/c48962de/job/src/main/java/org/apache/kylin/job/streaming/StreamingBootstrap.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/streaming/StreamingBootstrap.java b/job/src/main/java/org/apache/kylin/job/streaming/StreamingBootstrap.java
index ae6b282..07f2b05 100644
--- a/job/src/main/java/org/apache/kylin/job/streaming/StreamingBootstrap.java
+++ b/job/src/main/java/org/apache/kylin/job/streaming/StreamingBootstrap.java
@@ -269,6 +269,7 @@ public class StreamingBootstrap {
OneOffStreamBuilder oneOffStreamBuilder = new OneOffStreamBuilder(streamingConfig.getName(), queues, streamParser, new CubeStreamConsumer(cubeName), startTimestamp, endTimestamp, margin);
Executors.newSingleThreadExecutor().submit(oneOffStreamBuilder).get();
logger.info("one off build finished");
+ System.exit(0);
}
private void startIIStreaming(StreamingConfig streamingConfig, final int partitionId) throws Exception {