KYLIN-3173, reset DefaultScheduler's initialized/hasStarted when shutdown.
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/195fdef5 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/195fdef5 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/195fdef5 Branch: refs/heads/master Commit: 195fdef501ee03f5e31fdae81d282f3e0cf1ee0f Parents: a31bce6 Author: tttMelody <245915...@qq.com> Authored: Wed Jan 17 14:48:18 2018 +0800 Committer: Li Yang <liy...@apache.org> Committed: Fri Jan 26 22:54:58 2018 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/job/impl/threadpool/DefaultScheduler.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/195fdef5/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DefaultScheduler.java ---------------------------------------------------------------------- diff --git a/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DefaultScheduler.java b/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DefaultScheduler.java index 6af0192..0b01284 100644 --- a/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DefaultScheduler.java +++ b/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DefaultScheduler.java @@ -366,6 +366,8 @@ public class DefaultScheduler implements Scheduler<AbstractExecutable>, Connecti public void shutdown() throws SchedulerException { logger.info("Shutting down DefaultScheduler ...."); jobLock.unlockJobEngine(); + initialized = false; + hasStarted = false; try { fetcherPool.shutdownNow();//interrupt fetcherPool.awaitTermination(1, TimeUnit.MINUTES);
