Skip to content

Commit

Permalink
minor change
Browse files Browse the repository at this point in the history
  • Loading branch information
shiv0408 committed Aug 23, 2023
1 parent 0f78474 commit 0c81e3f
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -258,7 +258,6 @@ public HashMap<ShardRouting, AllocateUnassignedDecision> makeAllocationDecision(
);
// we are throttling this, as we have enough other shards to allocate to this node, so ignore it for now
shardAllocationDecisions.put(unassignedShard, AllocateUnassignedDecision.throttle(nodeDecisions));
continue;
} else {
logger.debug(
"[{}][{}]: allocating [{}] to [{}] in order to reuse its unallocated persistent store",
Expand All @@ -269,8 +268,8 @@ public HashMap<ShardRouting, AllocateUnassignedDecision> makeAllocationDecision(
);
// we found a match
shardAllocationDecisions.put(unassignedShard, AllocateUnassignedDecision.yes(nodeWithHighestMatch.node(), null, nodeDecisions, true));
continue;
}
continue;
} else if (matchingNodes.hasAnyData() == false && unassignedShard.unassignedInfo().isDelayed()) {
// if we didn't manage to find *any* data (regardless of matching sizes), and the replica is
// unassigned due to a node leaving, so we delay allocation of this replica to see if the
Expand Down

0 comments on commit 0c81e3f

Please sign in to comment.