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 <[email protected]> Authored: Fri Jun 16 21:24:14 2017 +0800 Committer: Roger Shi <[email protected]> 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; }
