enlarge the job interval in BuildCubeWithStream
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/dfb41765 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/dfb41765 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/dfb41765 Branch: refs/heads/orderedbytes Commit: dfb4176531046e212649dce89aebb8d091fc5689 Parents: 1e04981 Author: shaofengshi <shaofeng...@apache.org> Authored: Fri Sep 30 11:02:09 2016 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Fri Sep 30 11:02:09 2016 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/provision/BuildCubeWithStream.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/dfb41765/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 23d7ca8..b48f75b 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 @@ -22,9 +22,7 @@ import java.io.File; import java.io.IOException; import java.text.ParseException; import java.text.SimpleDateFormat; -import java.util.HashMap; import java.util.List; -import java.util.Map; import java.util.Random; import java.util.TimeZone; import java.util.UUID; @@ -179,7 +177,7 @@ public class BuildCubeWithStream { List<FutureTask<ExecutableState>> futures = Lists.newArrayList(); for (int i = 0; i < 5; i++) { - Thread.sleep(2 * 60 * 1000); // wait for new messages + Thread.sleep(5 * 60 * 1000); // wait for new messages FutureTask futureTask = new FutureTask(new Callable<ExecutableState>() { @Override public ExecutableState call() {