Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

bug fix for getNewNodes() in ListenerDiscoverer (#3092)

This commit is contained in:
Keuntae Park 2016-06-07 20:02:42 +09:00 committed by Nishant
parent 5a3db634ff
commit e6b32c24ae
2 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/src/main/java/io/druid/server/listener/announcer/ListenerDiscoverer.java
View File

@ -166,7 +166,7 @@ public class ListenerDiscoverer
}
}
);
lastSeenMap = priorSeenMap;
lastSeenMap = currentMap;
return retVal;
}

6
server/src/test/java/io/druid/server/listener/announcer/ListenerDiscovererTest.java
View File

@ -135,6 +135,12 @@ public class ListenerDiscovererTest extends CuratorTestBase
ImmutableSet.of(HostAndPort.fromString(node.toString())),
listenerDiscoverer.getNodes(listenerKey)
);
// 2nd call of two concurrent getNewNodes should return no entry collection
listenerDiscoverer.getNewNodes(listenerKey);
Assert.assertEquals(
0,
listenerDiscoverer.getNewNodes(listenerKey).size()
);
Assert.assertEquals(
ImmutableSet.of(listenerKey, listenerTier),
ImmutableSet.copyOf(listenerDiscoverer.discoverChildren(null))