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/03/12 04:54:22 UTC
kylin git commit: bug in BuildCubeWithStream in last commit
Repository: kylin
Updated Branches:
refs/heads/master 530549cf9 -> f0eca2414
bug in BuildCubeWithStream in last commit
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/f0eca241
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/f0eca241
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/f0eca241
Branch: refs/heads/master
Commit: f0eca24140b2a48e43b287bafe08f37e138e2df0
Parents: 530549c
Author: shaofengshi <sh...@apache.org>
Authored: Sun Mar 12 12:54:18 2017 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Sun Mar 12 12:54:18 2017 +0800
----------------------------------------------------------------------
.../kylin/provision/BuildCubeWithStream.java | 17 +++++++++--------
1 file changed, 9 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/f0eca241/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 2880bf4..c5341d6 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
@@ -198,15 +198,16 @@ public class BuildCubeWithStream {
if (i == (BUILD_ROUND - 1)) {
// stop generating message to kafka
generateData = false;
+ int waittime = 0;
+ while (generateDataDone == false && waittime < 100) {
+ Thread.sleep(1000);
+ waittime++;
+ }
+ if (generateDataDone == false) {
+ throw new IllegalStateException("Timeout when wait all messages be sent to Kafka"); // ensure all messages have been flushed.
+ }
}
- int waittime = 0;
- while (generateDataDone == false && waittime < 100) {
- Thread.sleep(1000);
- waittime++;
- }
- if (generateDataDone == false) {
- throw new IllegalStateException("Timeout when wait all messages be sent to Kafka"); // ensure all messages have been flushed.
- }
+
FutureTask futureTask = new FutureTask(new Callable<ExecutableState>() {
@Override
public ExecutableState call() {