Shard Allocation: Rename cluster.routing.allocation.concurrent_recoveries to cluster.routing.allocation.node_concurrent_recoveries (old one still works), closes #817.
This commit is contained in:
parent
7ce7fb33e5
commit
2dd5094d37
|
@ -36,7 +36,8 @@ public class ThrottlingNodeAllocation extends NodeAllocation {
|
||||||
@Inject public ThrottlingNodeAllocation(Settings settings) {
|
@Inject public ThrottlingNodeAllocation(Settings settings) {
|
||||||
super(settings);
|
super(settings);
|
||||||
|
|
||||||
this.concurrentRecoveries = componentSettings.getAsInt("concurrent_recoveries", 2);
|
this.concurrentRecoveries = componentSettings.getAsInt("concurrent_recoveries", componentSettings.getAsInt("node_concurrent_recoveries", 2));
|
||||||
|
logger.debug("using [concurrent_recoveries] with [{}]", concurrentRecoveries);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override public Decision canAllocate(ShardRouting shardRouting, RoutingNode node, RoutingAllocation allocation) {
|
@Override public Decision canAllocate(ShardRouting shardRouting, RoutingNode node, RoutingAllocation allocation) {
|
||||||
|
|
Loading…
Reference in New Issue