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 2017/12/31 13:19:37 UTC
[20/50] [abbrv] kylin git commit: KYLIN-3108,
Change the kafka config write path in zookeeper to
/kylin/streaming_config/UUID.
KYLIN-3108, Change the kafka config write path in zookeeper to /kylin/streaming_config/UUID.
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/9c856546
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/9c856546
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/9c856546
Branch: refs/heads/master
Commit: 9c8565465a7bc2d9b227900e3a6cf841e919d49e
Parents: f15da9e
Author: tttMelody <24...@qq.com>
Authored: Thu Dec 14 16:23:22 2017 +0800
Committer: Jiatao Tao <24...@qq.com>
Committed: Thu Dec 14 19:08:11 2017 +0800
----------------------------------------------------------------------
.../org/apache/kylin/provision/BuildCubeWithStream.java | 12 +++++++-----
1 file changed, 7 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/9c856546/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 60cea56..bf614af 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
@@ -90,7 +90,7 @@ public class BuildCubeWithStream {
private KafkaConfig kafkaConfig;
private MockKafka kafkaServer;
private ZkConnection zkConnection;
- private final String kafkaZkPath = "/" + UUID.randomUUID().toString();
+ private final String kafkaZkPath = "/kylin/streaming/" + UUID.randomUUID().toString();
protected static boolean fastBuildMode = false;
private volatile boolean generateData = true;
@@ -359,13 +359,15 @@ public class BuildCubeWithStream {
buildCubeWithStream.before();
buildCubeWithStream.build();
logger.info("Build is done");
-
- buildCubeWithStream.after();
- buildCubeWithStream.cleanup();
- logger.info("Going to exit");
} catch (Throwable e) {
logger.error("error", e);
exitCode = 1;
+ } finally{
+ if (buildCubeWithStream != null) {
+ buildCubeWithStream.after();
+ buildCubeWithStream.cleanup();
+ }
+ logger.info("Going to exit");
}
long millis = System.currentTimeMillis() - start;