Skip to content

Commit 5c496d0

Browse files
committed
Merge branch '08272025/ReshardAddShardCount' of github.com:ankikuma/elasticsearch into 08272025/ReshardAddShardCount
pull
2 parents 418b4ff + cab853d commit 5c496d0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

server/src/main/java/org/elasticsearch/cluster/metadata/IndexMetadata.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1158,13 +1158,13 @@ public int getNumberOfShards() {
11581158
* @return Effective shard count as seen by an operation using this IndexMetadata
11591159
*/
11601160
public int getReshardSplitShardCount(int shardId, IndexReshardingState.Split.TargetShardState minShardState) {
1161-
assert shardId >= 0 && shardId < getNumberOfShards(): "shardId is out of bounds";
1161+
assert shardId >= 0 && shardId < getNumberOfShards() : "shardId is out of bounds";
11621162
int shardCount = getNumberOfShards();
11631163
if (reshardingMetadata != null) {
11641164
if (reshardingMetadata.getSplit().isTargetShard(shardId)) {
11651165
// TODO: Assert that target state is atleast minShardState
11661166
int sourceShardId = reshardingMetadata.getSplit().sourceShard(shardId);
1167-
assert reshardingMetadata.getSplit().allTargetStatesAtLeast(sourceShardId, minShardState): "unexpected target state";
1167+
assert reshardingMetadata.getSplit().allTargetStatesAtLeast(sourceShardId, minShardState) : "unexpected target state";
11681168
shardCount = reshardingMetadata.getSplit().shardCountAfter();
11691169
} else if (reshardingMetadata.getSplit().isSourceShard(shardId)) {
11701170
if (reshardingMetadata.getSplit().allTargetStatesAtLeast(shardId, minShardState)) {

0 commit comments

Comments
 (0)