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/06/29 05:48:18 UTC
[11/50] kylin git commit: Support schedule streaming cube (#1148)
Support schedule streaming cube (#1148)
* Support schedule streaming cube
* Resume schedulers after login
* Set streaming cube's endOffset from Integer.MAX_VALUE to Long.MAX_VALUE
* Call AccessService apis only for rest apis.
* Resume scheduler jobs after scheduler service initialized.
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/81d26370
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/81d26370
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/81d26370
Branch: refs/heads/master
Commit: 81d26370c8365faf1de2c74cfb2af7869d786a1a
Parents: 6182589
Author: Ni Chunen <zj...@sjtu.org>
Authored: Fri Jun 16 21:24:14 2017 +0800
Committer: Roger Shi <ro...@gmail.com>
Committed: Fri Jun 16 21:24:14 2017 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/rest/service/JobService.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/81d26370/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java
----------------------------------------------------------------------
diff --git a/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java b/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java
index 7eb1292..6451d66 100644
--- a/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java
+++ b/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java
@@ -205,8 +205,13 @@ public class JobService extends BasicService implements InitializingBean {
public JobInstance submitJob(CubeInstance cube, long startDate, long endDate, long startOffset, long endOffset, //
Map<Integer, Long> sourcePartitionOffsetStart, Map<Integer, Long> sourcePartitionOffsetEnd,
CubeBuildTypeEnum buildType, boolean force, String submitter) throws IOException {
- return submitJobInternal(cube, startDate, endDate, startOffset, endOffset, sourcePartitionOffsetStart,
+ JobInstance jobInstance = submitJobInternal(cube, startDate, endDate, startOffset, endOffset, sourcePartitionOffsetStart,
sourcePartitionOffsetEnd, buildType, force, submitter);
+
+ accessService.init(jobInstance, null);
+ accessService.inherit(jobInstance, cube);
+
+ return jobInstance;
}
public JobInstance submitJobInternal(CubeInstance cube, long startDate, long endDate, long startOffset,
@@ -262,9 +267,6 @@ public class JobService extends BasicService implements InitializingBean {
JobInstance jobInstance = getSingleJobInstance(job);
- accessService.init(jobInstance, null);
- accessService.inherit(jobInstance, cube);
-
return jobInstance;
}