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 <245915...@qq.com> Authored: Thu Dec 14 16:23:22 2017 +0800 Committer: Jiatao Tao <245915...@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;