honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-03-01 08:29:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #16500 from ywelsch/fix/indexshard-relocating-before-recovery

Browse Source 
Relocation source should be marked as relocating before starting recovery to primary relocation target
This commit is contained in:
Yannick Welsch 2016-02-08 17:31:38 +01:00
commit 65d09b3484
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
core/src/main/java/org/elasticsearch/indices/recovery/RecoverySource.java
View File

@ -93,6 +93,14 @@ public class RecoverySource extends AbstractComponent implements IndexEventListe
logger.debug("delaying recovery of {} as source node {} is unknown", request.shardId(), request.targetNode());
throw new DelayRecoveryException("source node does not have the node [" + request.targetNode() + "] in its state yet..");
}
ShardRouting routingEntry = shard.routingEntry();
if (request.recoveryType() == RecoveryState.Type.PRIMARY_RELOCATION &&
(routingEntry.relocating() == false || routingEntry.relocatingNodeId().equals(request.targetNode().getId()) == false)) {
logger.debug("delaying recovery of {} as source shard is not marked yet as relocating to {}", request.shardId(), request.targetNode());
throw new DelayRecoveryException("source shard is not marked yet as relocating to [" + request.targetNode() + "]");
}
ShardRouting targetShardRouting = null;
for (ShardRouting shardRouting : node) {
if (shardRouting.shardId().equals(request.shardId())) {