minor, dont cache rest nodes in Broadcaster
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/5aeedd5c Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/5aeedd5c Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/5aeedd5c Branch: refs/heads/1.5.x-CDH5.7 Commit: 5aeedd5c7d11a282cc253e13247218bb2a0e3bf3 Parents: f2732ec Author: Yang Li <liy...@apache.org> Authored: Sat Sep 24 10:38:19 2016 +0800 Committer: Yang Li <liy...@apache.org> Committed: Sat Sep 24 10:38:38 2016 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/metadata/cachesync/Broadcaster.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/5aeedd5c/core-metadata/src/main/java/org/apache/kylin/metadata/cachesync/Broadcaster.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/cachesync/Broadcaster.java b/core-metadata/src/main/java/org/apache/kylin/metadata/cachesync/Broadcaster.java index 73dd0a7..380dac8 100644 --- a/core-metadata/src/main/java/org/apache/kylin/metadata/cachesync/Broadcaster.java +++ b/core-metadata/src/main/java/org/apache/kylin/metadata/cachesync/Broadcaster.java @@ -77,7 +77,8 @@ public class Broadcaster { } } - public static void clearCache() { + // call Broadcaster.getInstance().notifyClearAll() to clear cache + static void clearCache() { CACHE.clear(); } @@ -104,7 +105,7 @@ public class Broadcaster { @Override public void run() { final List<RestClient> restClients = Lists.newArrayList(); - for (String node : nodes) { + for (String node : config.getRestServers()) { restClients.add(new RestClient(node)); } final ExecutorService wipingCachePool = Executors.newFixedThreadPool(restClients.size());
