Package org.apache.cassandra.service

Class ActiveRepairService

java.lang.Object

org.apache.cassandra.service.ActiveRepairService

All Implemented Interfaces:

IEndpointStateChangeSubscriber, IFailureDetectionEventListener, ActiveRepairServiceMBean

public class ActiveRepairService
extends Object
implements IEndpointStateChangeSubscriber, IFailureDetectionEventListener, ActiveRepairServiceMBean

ActiveRepairService is the starting point for manual "active" repairs. Each user triggered repair will correspond to one or multiple repair session, one for each token range to repair. On repair session might repair multiple column families. For each of those column families, the repair session will request merkle trees for each replica of the range being repaired, diff those trees upon receiving them, schedule the streaming ofthe parts to repair (based on the tree diffs) and wait for all those operation. See RepairSession for more details. The creation of a repair session is done through the submitRepairSession that returns a future on the completion of that session.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ActiveRepairService.ConsistentSessions
static class	ActiveRepairService.ParentRepairSession	We keep a ParentRepairSession around for the duration of the entire repair, for example, on a 256 token vnode rf=3 cluster we would have 768 RepairSession but only one ParentRepairSession.
static enum	ActiveRepairService.ParentRepairStatus
static class	ActiveRepairService.RepairCommandExecutorHandle

Field Summary

Fields

Modifier and Type	Field	Description
final ActiveRepairService.ConsistentSessions	consistent
final SharedContext	ctx
static final TimeUUID	NO_PENDING_REPAIR
final ExecutorPlus	snapshotExecutor
static final long	UNREPAIRED_SSTABLE

Fields inherited from interface org.apache.cassandra.service.ActiveRepairServiceMBean

MBEAN_NAME

Constructor Summary

Constructors

Constructor	Description
ActiveRepairService()
ActiveRepairService(SharedContext ctx)

Method Summary

Modifier and Type	Method	Description
void	abort(Predicate<ActiveRepairService.ParentRepairSession> predicate, String message)	Remove any parent repair sessions matching predicate
void	beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)
void	cleanUp(TimeUUID parentRepairSession, Set<InetAddressAndPort> endpoints)	Send Verb.CLEANUP_MSG to the given endpoints.
List<CompositeData>	cleanupPending(List<String> schemaArgs, String rangeString, boolean force)
void	clearLocalRepairState()
void	convict(InetAddressAndPort ep, double phi)	Something has happened to a remote node - if that node is a coordinator, we mark the parent repair session id as failed.
CoordinatorState	coordinator(TimeUUID id)
Collection<CoordinatorState>	coordinators()
void	failSession(String session, boolean force)
int	getConcurrentMerkleTreeRequests()
double	getIncrementalRepairDiskHeadroomRejectRatio()
EndpointsForRange	getNeighbors(String keyspaceName, Iterable<Range<Token>> keyspaceLocalRanges, Range<Token> toRepair, Collection<String> dataCenters, Collection<String> hosts)	Return all of the neighbors with whom we share the provided range.
ActiveRepairService.ParentRepairSession	getParentRepairSession(TimeUUID parentSessionId)	We assume when calling this method that a parent session for the provided identifier exists, and that session is still in progress.
int	getPaxosRepairParallelism()
List<CompositeData>	getPendingStats(List<String> schemaArgs, String rangeString)
int	getRepairPendingCompactionRejectThreshold()
int	getRepairSessionSpaceInMebibytes()	Deprecated. See CASSANDRA-17668
int	getRepairSessionSpaceInMegabytes()	Deprecated. See CASSANDRA-15234
int	getRepairSessionSpaceInMiB()
List<CompositeData>	getRepairStats(List<String> schemaArgs, String rangeString)
Pair<ActiveRepairService.ParentRepairStatus,List<String>>	getRepairStatus(Integer cmd)
List<Map<String,String>>	getSessions(boolean all, String rangesStr)
boolean	getUseOffheapMerkleTrees()
void	handleMessage(Message<? extends RepairMessage> message)
static ActiveRepairService	instance()
void	onAlive(InetAddressAndPort endpoint, EndpointState state)
void	onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)
void	onDead(InetAddressAndPort endpoint, EndpointState state)
void	onJoin(InetAddressAndPort endpoint, EndpointState epState)	Use to inform interested parties about the change in the state for specified endpoint
void	onRemove(InetAddressAndPort endpoint)
void	onRestart(InetAddressAndPort endpoint, EndpointState state)	Called whenever a node is restarted.
int	parentRepairSessionCount()
int	parentRepairSessionsCount()	Each ongoing repair (incremental and non-incremental) is represented by a ActiveRepairService.ParentRepairSession entry in the ActiveRepairService cache.
ParticipateState	participate(TimeUUID id)
Collection<ParticipateState>	participates()
Future<?>	prepareForRepair(TimeUUID parentRepairSession, InetAddressAndPort coordinator, Set<InetAddressAndPort> endpoints, RepairOption options, boolean isForcedRepair, List<ColumnFamilyStore> columnFamilyStores)
void	recordRepairStatus(int cmd, ActiveRepairService.ParentRepairStatus parentRepairStatus, List<String> messages)
void	register(CoordinatorState state)
boolean	register(ParticipateState state)
void	registerParentRepairSession(TimeUUID parentRepairSession, InetAddressAndPort coordinator, List<ColumnFamilyStore> columnFamilyStores, Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, boolean isGlobal, PreviewKind previewKind)
ActiveRepairService.ParentRepairSession	removeParentRepairSession(TimeUUID parentSessionId)	called when the repair session is done - either failed or anticompaction has completed
static ExecutorPlus	repairCommandExecutor()
Future<?>	repairPaxosForTopologyChange(String ksName, Collection<Range<Token>> ranges, String reason)
int	sessionCount()
void	setConcurrentMerkleTreeRequests(int value)
void	setIncrementalRepairDiskHeadroomRejectRatio(double value)
void	setPaxosRepairParallelism(int v)
void	setRepairPendingCompactionRejectThreshold(int value)
void	setRepairSessionSpaceInMebibytes(int sizeInMebibytes)	Deprecated. See CASSANDRA-17668
void	setRepairSessionSpaceInMegabytes(int sizeInMegabytes)	Deprecated. See CASSANDRA-15234
void	setRepairSessionSpaceInMiB(int sizeInMebibytes)
void	setUseOffheapMerkleTrees(boolean value)
void	shutdownNowAndWait(long timeout, TimeUnit unit)
void	start()
void	stop()
RepairSession	submitRepairSession(TimeUUID parentRepairSession, CommonRange range, String keyspace, RepairParallelism parallelismDegree, boolean isIncremental, boolean pullRepair, PreviewKind previewKind, boolean optimiseStreams, boolean repairPaxos, boolean paxosOnly, ExecutorPlus executor, Scheduler validationScheduler, String... cfnames)	Requests repairs for the given keyspace and column families.
void	terminateSessions()
ValidationState	validation(UUID id)
Collection<ValidationState>	validations()
boolean	verifyCompactionsPendingThreshold(TimeUUID parentRepairSession, PreviewKind previewKind)
boolean	verifyDiskHeadroomThreshold(TimeUUID parentRepairSession, PreviewKind previewKind)

Methods inherited from class java.lang.Object

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

Field Details

consistent

public final ActiveRepairService.ConsistentSessions consistent

UNREPAIRED_SSTABLE

public static final long UNREPAIRED_SSTABLE

See Also:

• Constant Field Values

NO_PENDING_REPAIR

public static final TimeUUID NO_PENDING_REPAIR

ctx

public final SharedContext ctx

snapshotExecutor

public final ExecutorPlus snapshotExecutor

Constructor Details

ActiveRepairService

public ActiveRepairService()

ActiveRepairService

public ActiveRepairService(SharedContext ctx)

Method Details

instance

public static ActiveRepairService instance()

repairCommandExecutor

public static ExecutorPlus repairCommandExecutor()

start

public void start()

clearLocalRepairState

public void clearLocalRepairState()

stop

public void stop()

getSessions

public List<Map<String,String>> getSessions(boolean all,
 String rangesStr)

Specified by:

getSessions in interface ActiveRepairServiceMBean

failSession

public void failSession(String session,
 boolean force)

Specified by:

failSession in interface ActiveRepairServiceMBean

setRepairSessionSpaceInMegabytes

@Deprecated(since="4.1")
public void setRepairSessionSpaceInMegabytes(int sizeInMegabytes)

Deprecated.

See CASSANDRA-15234

Specified by:

setRepairSessionSpaceInMegabytes in interface ActiveRepairServiceMBean

getRepairSessionSpaceInMegabytes

@Deprecated(since="4.1")
public int getRepairSessionSpaceInMegabytes()

Deprecated.

See CASSANDRA-15234

Specified by:

getRepairSessionSpaceInMegabytes in interface ActiveRepairServiceMBean

setRepairSessionSpaceInMebibytes

@Deprecated(since="4.1")
public void setRepairSessionSpaceInMebibytes(int sizeInMebibytes)

Deprecated.

See CASSANDRA-17668

Specified by:

setRepairSessionSpaceInMebibytes in interface ActiveRepairServiceMBean

getRepairSessionSpaceInMebibytes

@Deprecated(since="4.1")
public int getRepairSessionSpaceInMebibytes()

Deprecated.

See CASSANDRA-17668

Specified by:

getRepairSessionSpaceInMebibytes in interface ActiveRepairServiceMBean

setRepairSessionSpaceInMiB

public void setRepairSessionSpaceInMiB(int sizeInMebibytes)

Specified by:

setRepairSessionSpaceInMiB in interface ActiveRepairServiceMBean

getRepairSessionSpaceInMiB

public int getRepairSessionSpaceInMiB()

Specified by:

getRepairSessionSpaceInMiB in interface ActiveRepairServiceMBean

getConcurrentMerkleTreeRequests

public int getConcurrentMerkleTreeRequests()

Specified by:

getConcurrentMerkleTreeRequests in interface ActiveRepairServiceMBean

setConcurrentMerkleTreeRequests

public void setConcurrentMerkleTreeRequests(int value)

Specified by:

setConcurrentMerkleTreeRequests in interface ActiveRepairServiceMBean

getRepairStats

public List<CompositeData> getRepairStats(List<String> schemaArgs,
 String rangeString)

Specified by:

getRepairStats in interface ActiveRepairServiceMBean

getPendingStats

public List<CompositeData> getPendingStats(List<String> schemaArgs,
 String rangeString)

Specified by:

getPendingStats in interface ActiveRepairServiceMBean

cleanupPending

public List<CompositeData> cleanupPending(List<String> schemaArgs,
 String rangeString,
 boolean force)

Specified by:

cleanupPending in interface ActiveRepairServiceMBean

parentRepairSessionsCount

public int parentRepairSessionsCount()

Description copied from interface: ActiveRepairServiceMBean

Each ongoing repair (incremental and non-incremental) is represented by a ActiveRepairService.ParentRepairSession entry in the ActiveRepairService cache. Returns the current number of ongoing repairs (the current number of cached entries).

Specified by:

parentRepairSessionsCount in interface ActiveRepairServiceMBean

Returns:

current size of the internal cache holding ActiveRepairService.ParentRepairSession instances

submitRepairSession

public RepairSession submitRepairSession(TimeUUID parentRepairSession,
 CommonRange range,
 String keyspace,
 RepairParallelism parallelismDegree,
 boolean isIncremental,
 boolean pullRepair,
 PreviewKind previewKind,
 boolean optimiseStreams,
 boolean repairPaxos,
 boolean paxosOnly,
 ExecutorPlus executor,
 Scheduler validationScheduler,
 String... cfnames)

Requests repairs for the given keyspace and column families.

Returns:

Future for asynchronous call or null if there is no need to repair

getUseOffheapMerkleTrees

public boolean getUseOffheapMerkleTrees()

Specified by:

getUseOffheapMerkleTrees in interface ActiveRepairServiceMBean

setUseOffheapMerkleTrees

public void setUseOffheapMerkleTrees(boolean value)

Specified by:

setUseOffheapMerkleTrees in interface ActiveRepairServiceMBean

terminateSessions

public void terminateSessions()

recordRepairStatus

public void recordRepairStatus(int cmd,
 ActiveRepairService.ParentRepairStatus parentRepairStatus,
 List<String> messages)

getRepairStatus

public Pair<ActiveRepairService.ParentRepairStatus,List<String>> getRepairStatus(Integer cmd)

getNeighbors

public EndpointsForRange getNeighbors(String keyspaceName,
 Iterable<Range<Token>> keyspaceLocalRanges,
 Range<Token> toRepair,
 Collection<String> dataCenters,
 Collection<String> hosts)

Return all of the neighbors with whom we share the provided range.

Parameters:

keyspaceName - keyspace to repair

keyspaceLocalRanges - local-range for given keyspaceName

toRepair - token to repair

dataCenters - the data centers to involve in the repair

Returns:

neighbors with whom we share the provided range

verifyCompactionsPendingThreshold

public boolean verifyCompactionsPendingThreshold(TimeUUID parentRepairSession,
 PreviewKind previewKind)

verifyDiskHeadroomThreshold

public boolean verifyDiskHeadroomThreshold(TimeUUID parentRepairSession,
 PreviewKind previewKind)

prepareForRepair

public Future<?> prepareForRepair(TimeUUID parentRepairSession,
 InetAddressAndPort coordinator,
 Set<InetAddressAndPort> endpoints,
 RepairOption options,
 boolean isForcedRepair,
 List<ColumnFamilyStore> columnFamilyStores)

cleanUp

public void cleanUp(TimeUUID parentRepairSession,
 Set<InetAddressAndPort> endpoints)

Send Verb.CLEANUP_MSG to the given endpoints. This results in removing parent session object from the endpoint's cache. This method does not throw an exception in case of a messaging failure.

registerParentRepairSession

public void registerParentRepairSession(TimeUUID parentRepairSession,
 InetAddressAndPort coordinator,
 List<ColumnFamilyStore> columnFamilyStores,
 Collection<Range<Token>> ranges,
 boolean isIncremental,
 long repairedAt,
 boolean isGlobal,
 PreviewKind previewKind)

getParentRepairSession

public ActiveRepairService.ParentRepairSession getParentRepairSession(TimeUUID parentSessionId)
                                                               throws NoSuchRepairSessionException

We assume when calling this method that a parent session for the provided identifier exists, and that session is still in progress. When it doesn't, that should mean either abort(Predicate, String) or failRepair(TimeUUID, String) have removed it.

Parameters:

parentSessionId - an identifier for an active parent repair session

Returns:

the ActiveRepairService.ParentRepairSession associated with the provided identifier

Throws:

NoSuchRepairSessionException - if the provided identifier does not map to an active parent session

removeParentRepairSession

public ActiveRepairService.ParentRepairSession removeParentRepairSession(TimeUUID parentSessionId)

called when the repair session is done - either failed or anticompaction has completed

clears out any snapshots created by this repair

Parameters:

parentSessionId - an identifier for an active parent repair session

Returns:

the ActiveRepairService.ParentRepairSession associated with the provided identifier

See Also:

• CassandraTableRepairManager.snapshot(String, Collection, boolean)

handleMessage

public void handleMessage(Message<? extends RepairMessage> message)

onJoin

public void onJoin(InetAddressAndPort endpoint,
 EndpointState epState)

Description copied from interface: IEndpointStateChangeSubscriber

Use to inform interested parties about the change in the state for specified endpoint

Specified by:

onJoin in interface IEndpointStateChangeSubscriber

Parameters:

endpoint - endpoint for which the state change occurred.

epState - state that actually changed for the above endpoint.

beforeChange

public void beforeChange(InetAddressAndPort endpoint,
 EndpointState currentState,
 ApplicationState newStateKey,
 VersionedValue newValue)

Specified by:

beforeChange in interface IEndpointStateChangeSubscriber

onChange

public void onChange(InetAddressAndPort endpoint,
 ApplicationState state,
 VersionedValue value)

Specified by:

onChange in interface IEndpointStateChangeSubscriber

onAlive

public void onAlive(InetAddressAndPort endpoint,
 EndpointState state)

Specified by:

onAlive in interface IEndpointStateChangeSubscriber

onDead

public void onDead(InetAddressAndPort endpoint,
 EndpointState state)

Specified by:

onDead in interface IEndpointStateChangeSubscriber

onRemove

public void onRemove(InetAddressAndPort endpoint)

Specified by:

onRemove in interface IEndpointStateChangeSubscriber

onRestart

public void onRestart(InetAddressAndPort endpoint,
 EndpointState state)

Description copied from interface: IEndpointStateChangeSubscriber

Called whenever a node is restarted. Note that there is no guarantee when that happens that the node was previously marked down. It will have only if state.isAlive() == false as state is from before the restarted node is marked up.

Specified by:

onRestart in interface IEndpointStateChangeSubscriber

convict

public void convict(InetAddressAndPort ep,
 double phi)

Something has happened to a remote node - if that node is a coordinator, we mark the parent repair session id as failed.

The fail marker is kept in the map for 24h to make sure that if the coordinator does not agree that the repair failed, we need to fail the entire repair session

Specified by:

convict in interface IFailureDetectionEventListener

Parameters:

ep - endpoint to be convicted

phi - the value of phi with with ep was convicted

getRepairPendingCompactionRejectThreshold

public int getRepairPendingCompactionRejectThreshold()

Specified by:

getRepairPendingCompactionRejectThreshold in interface ActiveRepairServiceMBean

setRepairPendingCompactionRejectThreshold

public void setRepairPendingCompactionRejectThreshold(int value)

Specified by:

setRepairPendingCompactionRejectThreshold in interface ActiveRepairServiceMBean

getIncrementalRepairDiskHeadroomRejectRatio

public double getIncrementalRepairDiskHeadroomRejectRatio()

Specified by:

getIncrementalRepairDiskHeadroomRejectRatio in interface ActiveRepairServiceMBean

setIncrementalRepairDiskHeadroomRejectRatio

public void setIncrementalRepairDiskHeadroomRejectRatio(double value)

Specified by:

setIncrementalRepairDiskHeadroomRejectRatio in interface ActiveRepairServiceMBean

abort

public void abort(Predicate<ActiveRepairService.ParentRepairSession> predicate,
 String message)

Remove any parent repair sessions matching predicate

parentRepairSessionCount

public int parentRepairSessionCount()

sessionCount

public int sessionCount()

repairPaxosForTopologyChange

public Future<?> repairPaxosForTopologyChange(String ksName,
 Collection<Range<Token>> ranges,
 String reason)

getPaxosRepairParallelism

public int getPaxosRepairParallelism()

Specified by:

getPaxosRepairParallelism in interface ActiveRepairServiceMBean

setPaxosRepairParallelism

public void setPaxosRepairParallelism(int v)

Specified by:

setPaxosRepairParallelism in interface ActiveRepairServiceMBean

shutdownNowAndWait

public void shutdownNowAndWait(long timeout,
 TimeUnit unit)
                        throws InterruptedException,
TimeoutException

Throws:

InterruptedException

TimeoutException

coordinators

public Collection<CoordinatorState> coordinators()

coordinator

public CoordinatorState coordinator(TimeUUID id)

register

public void register(CoordinatorState state)

register

public boolean register(ParticipateState state)

participates

public Collection<ParticipateState> participates()

participate

public ParticipateState participate(TimeUUID id)

validations

public Collection<ValidationState> validations()

validation

public ValidationState validation(UUID id)