From dca965a35add9542589fe7367dfdc007d44e0c8e Mon Sep 17 00:00:00 2001 From: Jae Hyeon Bae Date: Sun, 9 Feb 2014 22:26:18 -0800 Subject: [PATCH] curator 2.4.0 and Announcer logging lines are added regarding infos of reinstating --- pom.xml | 2 +- .../main/java/io/druid/curator/announcement/Announcer.java | 5 ++++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/pom.xml b/pom.xml index 9ec0e6f162c..ef438f8a7c2 100644 --- a/pom.xml +++ b/pom.xml @@ -40,7 +40,7 @@ UTF-8 0.25.3 - 2.3.0 + 2.4.0 0.1.8 diff --git a/server/src/main/java/io/druid/curator/announcement/Announcer.java b/server/src/main/java/io/druid/curator/announcement/Announcer.java index 3471ea60d87..f9ff444bf5e 100644 --- a/server/src/main/java/io/druid/curator/announcement/Announcer.java +++ b/server/src/main/java/io/druid/curator/announcement/Announcer.java @@ -207,10 +207,13 @@ public class Announcer Set pathsToReinstate = Sets.newHashSet(); for (String node : finalSubPaths.keySet()) { - pathsToReinstate.add(ZKPaths.makePath(parentPath, node)); + String path = ZKPaths.makePath(parentPath, node); + log.info("Node[%s] is added to reinstate.", path); + pathsToReinstate.add(path); } for (ChildData data : cache.getCurrentData()) { + log.info("Node[%s] in cache is removed to reinstate.", data.getPath()); pathsToReinstate.remove(data.getPath()); }