Package org.elasticsearch.cluster.routing.allocation.decider

Class MaxRetryAllocationDecider

java.lang.Object

org.elasticsearch.cluster.routing.allocation.decider.AllocationDecider

org.elasticsearch.cluster.routing.allocation.decider.MaxRetryAllocationDecider

public class MaxRetryAllocationDecider
extends AllocationDecider

An allocation decider that prevents shards from being allocated on any node if the shards allocation has been retried N times without success. This means if a shard has been INITIALIZING N times in a row without being moved to STARTED the shard will be ignored until the setting for index.allocation.max_retry is raised. The default value is 5. Note: This allocation decider also allows allocation of repeatedly failing shards when the /_cluster/reroute?retry_failed=true API is manually invoked. This allows single retries without raising the limits.

Field Summary

Fields

Modifier and Type	Field	Description
static String	NAME
static Setting<Integer>	SETTING_ALLOCATION_MAX_RETRY

Constructor Summary

Constructors

Constructor	Description
MaxRetryAllocationDecider()

Method Summary

Modifier and Type	Method	Description
Decision	canAllocate(ShardRouting shardRouting, RoutingAllocation allocation)	Returns a Decision whether the given shard routing can be allocated at all at this state of the RoutingAllocation.
Decision	canAllocate(ShardRouting shardRouting, RoutingNode node, RoutingAllocation allocation)	Returns a Decision whether the given shard routing can be allocated on the given node.
Decision	canForceAllocatePrimary(ShardRouting shardRouting, RoutingNode node, RoutingAllocation allocation)	Returns a Decision whether the given primary shard can be forcibly allocated on the given node.

Methods inherited from class org.elasticsearch.cluster.routing.allocation.decider.AllocationDecider

canAllocate, canRebalance, canRebalance, canRemain, shouldAutoExpandToNode

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

SETTING_ALLOCATION_MAX_RETRY

public static final Setting<Integer> SETTING_ALLOCATION_MAX_RETRY

NAME

public static final String NAME

See Also:

Constant Field Values

Constructor Details

MaxRetryAllocationDecider

public MaxRetryAllocationDecider()

Method Details

canAllocate

public Decision canAllocate(ShardRouting shardRouting,
 RoutingAllocation allocation)

Description copied from class: AllocationDecider

Returns a Decision whether the given shard routing can be allocated at all at this state of the RoutingAllocation. The default is Decision.ALWAYS.

Overrides:

canAllocate in class AllocationDecider

canAllocate

public Decision canAllocate(ShardRouting shardRouting,
 RoutingNode node,
 RoutingAllocation allocation)

Description copied from class: AllocationDecider

Returns a Decision whether the given shard routing can be allocated on the given node. The default is Decision.ALWAYS.

Overrides:

canAllocate in class AllocationDecider

canForceAllocatePrimary

public Decision canForceAllocatePrimary(ShardRouting shardRouting,
 RoutingNode node,
 RoutingAllocation allocation)

Description copied from class: AllocationDecider

Returns a Decision whether the given primary shard can be forcibly allocated on the given node. This method should only be called for unassigned primary shards where the node has a shard copy on disk. Note: all implementations that override this behavior should take into account the results of AllocationDecider.canAllocate(ShardRouting, RoutingNode, RoutingAllocation) before making a decision on force allocation, because force allocation should only be considered if all deciders return Decision.NO.

Overrides:

canForceAllocatePrimary in class AllocationDecider