Skip to content

Commit c974b59

Browse files
lktsmridula-s109
authored andcommitted
Fixes based on resharding disruption tests (elastic#130870)
1 parent 5370bd0 commit c974b59

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

server/src/main/java/org/elasticsearch/cluster/routing/RecoverySource.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -355,7 +355,7 @@ protected void writeAdditionalFields(StreamOutput out) throws IOException {
355355

356356
@Override
357357
public void addAdditionalFields(XContentBuilder builder, Params params) throws IOException {
358-
sourceShardId.toXContent(builder, params);
358+
builder.field("sourceShardId", sourceShardId);
359359
}
360360
}
361361
}

server/src/main/java/org/elasticsearch/indices/cluster/IndicesClusterStateService.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1004,8 +1004,8 @@ private static DiscoveryNode findSourceNodeForReshardSplitRecovery(
10041004
ShardRouting sourceShardRouting = routingTable.shardRoutingTable(sourceShardId).primaryShard();
10051005

10061006
if (sourceShardRouting.active() == false) {
1007-
assert false : sourceShardRouting.shortSummary();
1008-
logger.trace("can't find reshard split source node because source shard {} is not active.", sourceShardRouting);
1007+
// Source shard is unassigned (likely due to failure), we will retry.
1008+
logger.trace("can't find reshard split source node because source shard {} is not active.", sourceShardRouting.shortSummary());
10091009
return null;
10101010
}
10111011

0 commit comments

Comments
 (0)