fix exit
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/16dd4070 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/16dd4070 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/16dd4070 Branch: refs/heads/KYLIN-1356 Commit: 16dd4070ae41564f1e7fc69c47da8c54b8cf0417 Parents: 1bb69a9 Author: honma <ho...@ebay.com> Authored: Fri Jan 22 16:36:08 2016 +0800 Committer: honma <ho...@ebay.com> Committed: Fri Jan 22 16:36:08 2016 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/provision/BuildCubeWithEngine.java | 9 ++++++--- .../java/org/apache/kylin/provision/BuildCubeWithSpark.java | 7 ++++--- .../org/apache/kylin/provision/BuildCubeWithStream.java | 4 ++++ .../java/org/apache/kylin/provision/BuildIIWithEngine.java | 6 +++--- .../java/org/apache/kylin/provision/BuildIIWithStream.java | 3 +++ 5 files changed, 20 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/16dd4070/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 57c0568..32facf1 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 @@ -18,8 +18,6 @@ package org.apache.kylin.provision; -import static org.junit.Assert.assertEquals; - import java.io.File; import java.lang.reflect.Method; import java.text.SimpleDateFormat; @@ -71,7 +69,10 @@ public class BuildCubeWithEngine { BuildCubeWithEngine buildCubeWithEngine = new BuildCubeWithEngine(); buildCubeWithEngine.before(); buildCubeWithEngine.build(); + logger.info("Build is done"); afterClass(); + logger.info("Going to exit"); + System.exit(0); } public static void beforeClass() throws Exception { @@ -174,7 +175,9 @@ public class BuildCubeWithEngine { } private void assertJobSucceed(String jobId) { - assertEquals("The job '" + jobId + "' is failed.", ExecutableState.SUCCEED, jobService.getOutput(jobId).getState()); + if (jobService.getOutput(jobId).getState() != ExecutableState.SUCCEED) { + throw new RuntimeException("The job '" + jobId + "' is failed."); + } } private class TestCallable implements Callable<List<String>> { http://git-wip-us.apache.org/repos/asf/kylin/blob/16dd4070/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithSpark.java ---------------------------------------------------------------------- diff --git a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithSpark.java b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithSpark.java index 8ef0ec5..5ab5e83 100644 --- a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithSpark.java +++ b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithSpark.java @@ -18,8 +18,6 @@ package org.apache.kylin.provision; -import static org.junit.Assert.assertEquals; - import java.io.File; import java.text.SimpleDateFormat; import java.util.List; @@ -127,7 +125,10 @@ public class BuildCubeWithSpark { final DefaultChainedExecutable cubingJob = new SparkBatchCubingEngine(confPath, coprocessor).createBatchCubingJob(segment, "BuildCubeWithSpark"); jobService.addJob(cubingJob); waitForJob(cubingJob.getId()); - assertEquals(ExecutableState.SUCCEED, jobService.getOutput(cubingJob.getId()).getState()); + + if (jobService.getOutput(cubingJob.getId()).getState() != ExecutableState.SUCCEED) { + throw new RuntimeException("The job '" + cubingJob.getId() + "' is failed."); + } } private void clearSegment(String cubeName) throws Exception { http://git-wip-us.apache.org/repos/asf/kylin/blob/16dd4070/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 e5d669e..27226e7 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 @@ -54,7 +54,11 @@ public class BuildCubeWithStream { BuildCubeWithStream buildCubeWithStream = new BuildCubeWithStream(); buildCubeWithStream.before(); buildCubeWithStream.build(); + logger.info("Build is done"); afterClass(); + logger.info("Going to exit"); + System.exit(0); + } public static void beforeClass() throws Exception { http://git-wip-us.apache.org/repos/asf/kylin/blob/16dd4070/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithEngine.java ---------------------------------------------------------------------- diff --git a/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithEngine.java b/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithEngine.java index c08b978..4b8ce24 100644 --- a/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithEngine.java +++ b/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithEngine.java @@ -18,8 +18,6 @@ package org.apache.kylin.provision; -import static org.junit.Assert.assertEquals; - import java.io.File; import java.lang.reflect.Method; import java.text.SimpleDateFormat; @@ -167,7 +165,9 @@ public class BuildIIWithEngine { } private void assertJobSucceed(String jobId) { - assertEquals(ExecutableState.SUCCEED, jobService.getOutput(jobId).getState()); + if (jobService.getOutput(jobId).getState() != ExecutableState.SUCCEED) { + throw new RuntimeException("The job '" + jobId + "' is failed."); + } } private class TestCallable implements Callable<List<String>> { http://git-wip-us.apache.org/repos/asf/kylin/blob/16dd4070/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithStream.java ---------------------------------------------------------------------- diff --git a/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithStream.java b/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithStream.java index 46b63f0..8436687 100644 --- a/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithStream.java +++ b/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithStream.java @@ -96,7 +96,10 @@ public class BuildIIWithStream { BuildIIWithStream buildCubeWithEngine = new BuildIIWithStream(); buildCubeWithEngine.before(); buildCubeWithEngine.build(); + logger.info("Build is done"); afterClass(); + logger.info("Going to exit"); + System.exit(0); } public static void beforeClass() throws Exception {
