mirror of https://github.com/apache/druid.git
fix druid master segments getting stuck bug
This commit is contained in:
parent
3e8406a2e6
commit
a190269faa
|
@ -728,6 +728,7 @@ public class DruidMaster
|
|||
|
||||
// Stop peons for servers that aren't there anymore.
|
||||
for (String name : Sets.difference(
|
||||
loadManagementPeons.keySet(),
|
||||
Sets.newHashSet(
|
||||
Iterables.transform(
|
||||
servers,
|
||||
|
@ -740,7 +741,7 @@ public class DruidMaster
|
|||
}
|
||||
}
|
||||
)
|
||||
), loadManagementPeons.keySet()
|
||||
)
|
||||
)) {
|
||||
log.info("Removing listener for server[%s] which is no longer there.", name);
|
||||
LoadQueuePeon peon = loadManagementPeons.remove(name);
|
||||
|
|
Loading…
Reference in New Issue