kylin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From liy...@apache.org
Subject [43/48] kylin git commit: bug in BuildCubeWithStream in last commit
Date Sun, 12 Mar 2017 11:49:15 GMT
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-hbase0.98
Commit: f0eca24140b2a48e43b287bafe08f37e138e2df0
Parents: 530549c
Author: shaofengshi <shaofengshi@apache.org>
Authored: Sun Mar 12 12:54:18 2017 +0800
Committer: shaofengshi <shaofengshi@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() {


Mime
View raw message