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 2018/01/26 14:56:39 UTC
[31/34] kylin git commit: KYLIN-3173,
reset DefaultScheduler's initialized/hasStarted when shutdown.
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 <24...@qq.com>
Authored: Wed Jan 17 14:48:18 2018 +0800
Committer: Li Yang <li...@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);