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 2016/09/23 14:11:22 UTC
kylin git commit: log
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 <li...@apache.org>
Authored: Fri Sep 23 22:11:05 2016 +0800
Committer: Yang Li <li...@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);
}
/**