parent
66b5ed86f7
commit
e684d7fde4
|
@ -117,13 +117,13 @@ public class TransportNodesListGatewayStartedShards extends TransportNodesOperat
|
||||||
@Override
|
@Override
|
||||||
protected NodeGatewayStartedShards nodeOperation(NodeRequest request) throws ElasticsearchException {
|
protected NodeGatewayStartedShards nodeOperation(NodeRequest request) throws ElasticsearchException {
|
||||||
try {
|
try {
|
||||||
logger.trace("loading shard state info for {}", request.shardId);
|
logger.trace("{} loading local shard state info", request.shardId);
|
||||||
ShardStateInfo shardStateInfo = shardsState.loadShardInfo(request.shardId);
|
ShardStateInfo shardStateInfo = shardsState.loadShardInfo(request.shardId);
|
||||||
if (shardStateInfo != null) {
|
if (shardStateInfo != null) {
|
||||||
logger.debug("{} shard state info found: [{}]", request.shardId, shardStateInfo);
|
logger.debug("{} shard state info found: [{}]", request.shardId, shardStateInfo);
|
||||||
return new NodeGatewayStartedShards(clusterService.localNode(), shardStateInfo.version);
|
return new NodeGatewayStartedShards(clusterService.localNode(), shardStateInfo.version);
|
||||||
}
|
}
|
||||||
logger.trace("no shard info found for {}", request.shardId);
|
logger.trace("{} no local shard info found", request.shardId);
|
||||||
return new NodeGatewayStartedShards(clusterService.localNode(), -1);
|
return new NodeGatewayStartedShards(clusterService.localNode(), -1);
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
throw new ElasticsearchException("failed to load started shards", e);
|
throw new ElasticsearchException("failed to load started shards", e);
|
||||||
|
|
|
@ -186,9 +186,9 @@ public class TransportNodesListShardStoreMetaData extends TransportNodesOperatio
|
||||||
} finally {
|
} finally {
|
||||||
TimeValue took = new TimeValue(System.currentTimeMillis() - startTime);
|
TimeValue took = new TimeValue(System.currentTimeMillis() - startTime);
|
||||||
if (exists) {
|
if (exists) {
|
||||||
logger.debug("loaded store meta data for {} (took [{}])", shardId, took);
|
logger.debug("{} loaded store meta data (took [{}])", shardId, took);
|
||||||
} else {
|
} else {
|
||||||
logger.trace("loaded store meta data for {} (took [{}])", shardId, took);
|
logger.trace("{} didn't find any store meta data to load (took [{}])", shardId, took);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue