Skip to content

Commit 56dfacb

Browse files
committed
tweak
1 parent 830ce51 commit 56dfacb

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

server/src/main/java/org/elasticsearch/cluster/routing/allocation/allocator/DesiredBalanceComputer.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -502,10 +502,10 @@ private void maybeLogAllocationExplainForUnassigned(
502502
assert lastTrackedUnassignedShard == null : "unexpected non-null lastTrackedUnassignedShard " + lastTrackedUnassignedShard;
503503
if (routingNodes.hasUnassignedShards() && finishReason == DesiredBalance.ComputationFinishReason.CONVERGED) {
504504
final Predicate<ShardRouting> predicate = routingNodes.hasUnassignedPrimaries() ? ShardRouting::primary : shard -> true;
505-
lastTrackedUnassignedShard = Stream.concat(
506-
routingNodes.unassigned().stream(),
507-
routingNodes.unassigned().ignored().stream().filter(predicate)
508-
).findFirst().orElseThrow();
505+
lastTrackedUnassignedShard = Stream.concat(routingNodes.unassigned().stream(), routingNodes.unassigned().ignored().stream())
506+
.filter(predicate)
507+
.findFirst()
508+
.orElseThrow();
509509

510510
final var originalDebugMode = routingAllocation.getDebugMode();
511511
routingAllocation.setDebugMode(RoutingAllocation.DebugMode.EXCLUDE_YES_DECISIONS);

0 commit comments

Comments
 (0)