Repository: kylin Updated Branches: refs/heads/KYILN-2317 172b4279f -> 5b13287d8
fix daemon thread Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/5b13287d Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/5b13287d Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/5b13287d Branch: refs/heads/KYILN-2317 Commit: 5b13287d8b112a42d749cfd35b6312a3df32bf6b Parents: 172b427 Author: Billy Liu <[email protected]> Authored: Thu Dec 29 14:23:51 2016 +0800 Committer: Billy Liu <[email protected]> Committed: Thu Dec 29 14:23:51 2016 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/metadata/cachesync/Broadcaster.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/5b13287d/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 70d3ea9..d00c490 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 @@ -115,7 +115,7 @@ public class Broadcaster { for (String node : config.getRestServers()) { restClients.add(new RestClient(node)); } - final ExecutorService wipingCachePool = Executors.newFixedThreadPool(restClients.size()); + final ExecutorService wipingCachePool = Executors.newFixedThreadPool(restClients.size(), new DaemonThreadFactory()); while (true) { try { final BroadcastEvent broadcastEvent = broadcastEvents.takeFirst(); @@ -228,7 +228,7 @@ public class Broadcaster { try { counter.incrementAndGet(); - broadcastEvents.putFirst(new BroadcastEvent(entity, event, key)); + broadcastEvents.putLast(new BroadcastEvent(entity, event, key)); } catch (Exception e) { counter.decrementAndGet(); logger.error("error putting BroadcastEvent", e);
