KYLIN-1726 fix BuildCubeWithStream
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/8f1fb6ac Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/8f1fb6ac Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/8f1fb6ac Branch: refs/heads/orderedbytes3 Commit: 8f1fb6ac47b9fcf22090080b86d2ea98cc9d6132 Parents: 3d0954d Author: Hongbin Ma <mahong...@apache.org> Authored: Sat Oct 8 14:08:41 2016 +0800 Committer: Hongbin Ma <mahong...@apache.org> Committed: Sun Oct 16 13:27:26 2016 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/provision/BuildCubeWithStream.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/8f1fb6ac/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 fed14d8..c2fb180 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 @@ -18,6 +18,8 @@ package org.apache.kylin.provision; +import static java.lang.Thread.sleep; + import java.io.File; import java.io.IOException; import java.text.ParseException; @@ -32,7 +34,6 @@ import java.util.concurrent.Executors; import java.util.concurrent.FutureTask; import java.util.concurrent.TimeUnit; -import com.google.common.collect.Lists; import org.I0Itec.zkclient.ZkConnection; import org.apache.commons.lang3.StringUtils; import org.apache.kafka.common.requests.MetadataResponse; @@ -64,7 +65,7 @@ import org.junit.Assert; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import static java.lang.Thread.sleep; +import com.google.common.collect.Lists; /** * for streaming cubing case "test_streaming_table" @@ -323,6 +324,5 @@ public class BuildCubeWithStream { logger.error("error", e); System.exit(1); } - } }