Repository: kylin Updated Branches: refs/heads/KYLIN-2033 efa6debb7 -> dd1ab5271
log Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/dd1ab527 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/dd1ab527 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/dd1ab527 Branch: refs/heads/KYLIN-2033 Commit: dd1ab5271fb75abf9afd670ece2852736d12e6a3 Parents: efa6deb Author: Yang Li <liy...@apache.org> Authored: Fri Sep 23 22:11:05 2016 +0800 Committer: Yang Li <liy...@apache.org> Committed: Fri Sep 23 22:11:05 2016 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/metadata/cachesync/Broadcaster.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/dd1ab527/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 ec56cfd..73dd0a7 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 @@ -111,7 +111,7 @@ public class Broadcaster { while (true) { try { final BroadcastEvent broadcastEvent = broadcastEvents.takeFirst(); - logger.info("new broadcast event:" + broadcastEvent); + logger.info("Announcing new broadcast event:" + broadcastEvent); for (final RestClient restClient : restClients) { wipingCachePool.execute(new Runnable() { @Override @@ -138,7 +138,6 @@ public class Broadcaster { if (all != null && all.contains(listener)) { return; } - logger.debug("registering no. " + (all == null ? 0 : all.size()) + " listener " + listener); for (String entity : entities) { if (!StringUtils.isBlank(entity)) @@ -175,7 +174,7 @@ public class Broadcaster { if (list == null) return; - logger.debug("Broadcast metadata change: entity=" + entity + ", event=" + event + ", cacheKey=" + cacheKey + ", listeners=" + list); + logger.debug("Broadcasting metadata change: entity=" + entity + ", event=" + event + ", cacheKey=" + cacheKey + ", listeners=" + list); // prevents concurrent modification exception list = Lists.newArrayList(list); @@ -205,7 +204,7 @@ public class Broadcaster { break; } - logger.debug("Broadcast metadata change done"); + logger.debug("Done broadcasting metadata change: entity=" + entity + ", event=" + event + ", cacheKey=" + cacheKey); } /**
