minor fix ci
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/663a6f93 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/663a6f93 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/663a6f93 Branch: refs/heads/master-hbase0.98 Commit: 663a6f939f2fed83f096daf8a3a55ed3f785e5a0 Parents: 5d83c80 Author: shaofengshi <shaofeng...@apache.org> Authored: Sun Feb 5 09:57:34 2017 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Sun Feb 5 09:57:34 2017 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/provision/BuildCubeWithStream.java | 12 +++++++++--- .../test/java/org/apache/kylin/query/KylinTestBase.java | 2 +- 2 files changed, 10 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/663a6f93/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 37ff8ae..53c89cf 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 @@ -87,6 +87,8 @@ public class BuildCubeWithStream { protected static boolean fastBuildMode = false; private boolean generateData = true; + private static final int BUILD_ROUND = 5; + public void before() throws Exception { deployEnv(); @@ -181,8 +183,12 @@ public class BuildCubeWithStream { ExecutorService executorService = Executors.newCachedThreadPool(); List<FutureTask<ExecutableState>> futures = Lists.newArrayList(); - for (int i = 0; i < 5; i++) { - Thread.sleep(2 * 60 * 1000); // wait for new messages + for (int i = 0; i < BUILD_ROUND; i++) { + if (i == (BUILD_ROUND - 1)) { + // stop generating message to kafka + generateData = false; + } + Thread.sleep(1 * 60 * 1000); // wait for new messages FutureTask futureTask = new FutureTask(new Callable<ExecutableState>() { @Override public ExecutableState call() { @@ -202,7 +208,7 @@ public class BuildCubeWithStream { futures.add(futureTask); } - generateData = false; // stop generating message to kafka + generateData = false; executorService.shutdown(); int succeedBuild = 0; for (int i = 0; i < futures.size(); i++) { http://git-wip-us.apache.org/repos/asf/kylin/blob/663a6f93/kylin-it/src/test/java/org/apache/kylin/query/KylinTestBase.java ---------------------------------------------------------------------- diff --git a/kylin-it/src/test/java/org/apache/kylin/query/KylinTestBase.java b/kylin-it/src/test/java/org/apache/kylin/query/KylinTestBase.java index 1cc5c76..6b9397d 100644 --- a/kylin-it/src/test/java/org/apache/kylin/query/KylinTestBase.java +++ b/kylin-it/src/test/java/org/apache/kylin/query/KylinTestBase.java @@ -646,7 +646,7 @@ public class KylinTestBase { cubeConnection = DriverManager.getConnection("jdbc:calcite:model=" + olapTmp.getAbsolutePath(), props); //setup h2 - h2Connection = DriverManager.getConnection("jdbc:h2:mem:db" + (h2InstanceCount++) + ";CACHE_SIZE=32072;DB_CLOSE_DELAY=-1", "sa", ""); + h2Connection = DriverManager.getConnection("jdbc:h2:mem:db" + (h2InstanceCount++) + ";CACHE_SIZE=32072", "sa", ""); // Load H2 Tables (inner join) H2Database h2DB = new H2Database(h2Connection, config); h2DB.loadAllTables();
