Skip to content

Commit 67e92fd

Browse files
nicer checks
1 parent 321cf67 commit 67e92fd

File tree

1 file changed

+2
-8
lines changed

1 file changed

+2
-8
lines changed

server/src/main/java/org/elasticsearch/indices/ShardLimitValidator.java

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -213,17 +213,11 @@ private static int nodeCount(ClusterState state, Predicate<DiscoveryNode> nodePr
213213
}
214214

215215
private static boolean hasFrozen(DiscoveryNode node) {
216-
final List<DiscoveryNodeRole> dataRoles =
217-
node.getRoles().stream().filter(DiscoveryNodeRole::canContainData).collect(Collectors.toUnmodifiableList());
218-
219-
return dataRoles.contains(DiscoveryNodeRole.DATA_FROZEN_NODE_ROLE);
216+
return node.getRoles().contains(DiscoveryNodeRole.DATA_FROZEN_NODE_ROLE);
220217
}
221218

222219
private static boolean hasNonFrozen(DiscoveryNode node) {
223-
final List<DiscoveryNodeRole> dataRoles =
224-
node.getRoles().stream().filter(DiscoveryNodeRole::canContainData).collect(Collectors.toUnmodifiableList());
225-
226-
return dataRoles.size() > 1 || dataRoles.contains(DiscoveryNodeRole.DATA_FROZEN_NODE_ROLE) == false;
220+
return node.getRoles().stream().anyMatch(r -> r.canContainData() && r != DiscoveryNodeRole.DATA_FROZEN_NODE_ROLE);
227221
}
228222

229223
}

0 commit comments

Comments
 (0)