Revert "stop scheduler on test finish" This reverts commit 023b5cb1dfdacfa9adcc2586b4aaeb3886f61098.
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/c68bba0e Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/c68bba0e Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/c68bba0e Branch: refs/heads/tempmaster Commit: c68bba0e27984be5ac6e78945dbef8c46c6d2a61 Parents: 34970d9 Author: Hongbin Ma <mahong...@apache.org> Authored: Mon Sep 19 23:49:28 2016 +0800 Committer: Hongbin Ma <mahong...@apache.org> Committed: Mon Sep 19 23:49:28 2016 +0800 ---------------------------------------------------------------------- .../apache/kylin/job/impl/threadpool/BaseSchedulerTest.java | 1 - .../java/org/apache/kylin/provision/BuildCubeWithEngine.java | 6 ------ .../java/org/apache/kylin/provision/BuildCubeWithStream.java | 1 - .../java/org/apache/kylin/provision/BuildCubeWithStream2.java | 1 - 4 files changed, 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/c68bba0e/core-job/src/test/java/org/apache/kylin/job/impl/threadpool/BaseSchedulerTest.java ---------------------------------------------------------------------- diff --git a/core-job/src/test/java/org/apache/kylin/job/impl/threadpool/BaseSchedulerTest.java b/core-job/src/test/java/org/apache/kylin/job/impl/threadpool/BaseSchedulerTest.java index 97c9f8d..4e092a1 100644 --- a/core-job/src/test/java/org/apache/kylin/job/impl/threadpool/BaseSchedulerTest.java +++ b/core-job/src/test/java/org/apache/kylin/job/impl/threadpool/BaseSchedulerTest.java @@ -55,7 +55,6 @@ public abstract class BaseSchedulerTest extends LocalFileMetadataTestCase { @After public void after() throws Exception { - DefaultScheduler.destroyInstance(); cleanupTestMetadata(); } http://git-wip-us.apache.org/repos/asf/kylin/blob/c68bba0e/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java ---------------------------------------------------------------------- diff --git a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java index 31cf0eb..3d60a3c 100644 --- a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java +++ b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java @@ -79,7 +79,6 @@ public class BuildCubeWithEngine { BuildCubeWithEngine buildCubeWithEngine = new BuildCubeWithEngine(); buildCubeWithEngine.before(); buildCubeWithEngine.build(); - buildCubeWithEngine.after(); logger.info("Build is done"); afterClass(); logger.info("Going to exit"); @@ -149,11 +148,6 @@ public class BuildCubeWithEngine { } - - public void after(){ - DefaultScheduler.destroyInstance(); - } - public static void afterClass() { HBaseMetadataTestCase.staticCleanupTestMetadata(); } http://git-wip-us.apache.org/repos/asf/kylin/blob/c68bba0e/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java ---------------------------------------------------------------------- diff --git a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java index 6e5313f..b7c609e 100644 --- a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java +++ b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java @@ -217,7 +217,6 @@ public class BuildCubeWithStream { public void after() { kafkaServer.stop(); - DefaultScheduler.destroyInstance(); } protected void waitForJob(String jobId) { http://git-wip-us.apache.org/repos/asf/kylin/blob/c68bba0e/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream2.java ---------------------------------------------------------------------- diff --git a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream2.java b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream2.java index 2812446..d48a473 100644 --- a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream2.java +++ b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream2.java @@ -235,7 +235,6 @@ public class BuildCubeWithStream2 { public void after() { kafkaServer.stop(); - DefaultScheduler.destroyInstance(); } protected void waitForJob(String jobId) {
