- All Implemented Interfaces:
public class DelayedAllocationService extends AbstractLifecycleComponent implements ClusterStateListener
DelayedAllocationServicelistens to cluster state changes and checks if there are unassigned shards with delayed allocation (unassigned shards that have the delay marker). These are shards that have become unassigned due to a node leaving and which were assigned the delay marker based on the index delay setting
AllocationService.disassociateDeadNodes(RoutingAllocation). This class is responsible for choosing the next (closest) delay expiration of a delayed shard to schedule a reroute to remove the delay marker. The actual removal of the delay marker happens in
AllocationService.removeDelayMarkers(RoutingAllocation), triggering yet another cluster change event.
Modifier and Type Method Description
clusterChanged(ClusterChangedEvent event)Called when cluster state changes.
currentNanoTime()override this to control time based decisions during delayed allocation
Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop
protected void doStart()
protected void doStop()
protected void doClose()
protected long currentNanoTime()override this to control time based decisions during delayed allocation
public void clusterChanged(ClusterChangedEvent event)Description copied from interface:
ClusterStateListenerCalled when cluster state changes.
protected void assertClusterOrMasterStateThread()