honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 10:25:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added some debug logs to the recovery process

Browse Source
This commit is contained in:
Boaz Leskes 2014-05-15 15:37:30 +02:00
parent e47de1f809
commit dc07ece790
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -97,6 +97,7 @@ public class RecoverySource extends AbstractComponent {
// the index operations will not be routed to it properly // the index operations will not be routed to it properly
RoutingNode node = clusterService.state().readOnlyRoutingNodes().node(request.targetNode().id()); RoutingNode node = clusterService.state().readOnlyRoutingNodes().node(request.targetNode().id());
if (node == null) { if (node == null) {
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.."); throw new DelayRecoveryException("source node does not have the node [" + request.targetNode() + "] in its state yet..");
} }
ShardRouting targetShardRouting = null; ShardRouting targetShardRouting = null;
@ -107,9 +108,12 @@ public class RecoverySource extends AbstractComponent {
} }
} }
if (targetShardRouting == null) { if (targetShardRouting == null) {
logger.debug("delaying recovery of {} as it is not listed as assigned to target node {}", request.shardId(), request.targetNode());
throw new DelayRecoveryException("source node does not have the shard listed in its state as allocated on the node"); throw new DelayRecoveryException("source node does not have the shard listed in its state as allocated on the node");
} }
if (!targetShardRouting.initializing()) { if (!targetShardRouting.initializing()) {
logger.debug("delaying recovery of {} as it is not listed as initializing on the target node {}. known shards state is [{}]",
request.shardId(), request.targetNode(), targetShardRouting.state());
throw new DelayRecoveryException("source node has the state of the target shard to be [" + targetShardRouting.state() + "], expecting to be [initializing]"); throw new DelayRecoveryException("source node has the state of the target shard to be [" + targetShardRouting.state() + "], expecting to be [initializing]");
} }