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 <shaofeng...@apache.org> Authored: Sun Mar 12 12:54:18 2017 +0800 Committer: shaofengshi <shaofeng...@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() {
