You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2017/02/05 01:57:50 UTC
kylin git commit: minor fix ci
Repository: kylin
Updated Branches:
refs/heads/master 5d83c80fb -> 663a6f939
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
Commit: 663a6f939f2fed83f096daf8a3a55ed3f785e5a0
Parents: 5d83c80
Author: shaofengshi <sh...@apache.org>
Authored: Sun Feb 5 09:57:34 2017 +0800
Committer: shaofengshi <sh...@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();