You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2015/03/28 01:05:25 UTC
[48/50] incubator-kylin git commit: fix
fix
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/c043b858
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/c043b858
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/c043b858
Branch: refs/heads/streaming-localdict
Commit: c043b8588673ef282759b0144d2448dddd13145e
Parents: b5a78a6 a3ff2d9
Author: qianhao.zhou <qi...@ebay.com>
Authored: Fri Mar 27 18:27:03 2015 +0800
Committer: qianhao.zhou <qi...@ebay.com>
Committed: Fri Mar 27 18:27:03 2015 +0800
----------------------------------------------------------------------
.../org/apache/kylin/job/cube/CubingJobBuilder.java | 2 --
.../org/apache/kylin/job/BuildCubeWithEngineTest.java | 7 ++-----
.../java/org/apache/kylin/job/IIStreamBuilderTest.java | 12 ++++++------
.../kylin/job/hadoop/invertedindex/II2CubeTest.java | 2 ++
4 files changed, 10 insertions(+), 13 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/c043b858/job/src/test/java/org/apache/kylin/job/IIStreamBuilderTest.java
----------------------------------------------------------------------
diff --cc job/src/test/java/org/apache/kylin/job/IIStreamBuilderTest.java
index bafcb61,3e352ff..d15d1e5
--- a/job/src/test/java/org/apache/kylin/job/IIStreamBuilderTest.java
+++ b/job/src/test/java/org/apache/kylin/job/IIStreamBuilderTest.java
@@@ -96,13 -68,13 +96,13 @@@ public class IIStreamBuilderTest extend
DeployUtil.overrideJobJarLocations();
}
- @After
- public void after() {
- this.cleanupTestMetadata();
- }
-
@Test
public void test() throws Exception {
- // final StreamingBootstrap bootstrap = StreamingBootstrap.getInstance(kylinConfig);
- // bootstrap.start("eagle", 0);
- // Thread.sleep(30 * 60 * 1000);
- // logger.info("time is up, stop streaming");
- // bootstrap.stop();
- // Thread.sleep(5 * 1000);
- //StreamingBootstrap.getInstance(kylinConfig).startStreaming("eagle", 0);
++ final StreamingBootstrap bootstrap = StreamingBootstrap.getInstance(kylinConfig);
++ bootstrap.start("eagle", 0);
++ Thread.sleep(30 * 60 * 1000);
++ logger.info("time is up, stop streaming");
++ bootstrap.stop();
++ Thread.sleep(5 * 1000);
}
}