Package com.linkedin.venice.controller.systemstore

Class SystemStoreRepairTask

java.lang.Object

com.linkedin.venice.controller.systemstore.SystemStoreRepairTask

All Implemented Interfaces:

Runnable

public class SystemStoreRepairTask
extends Object
implements Runnable

This class tries to scan all clusters for which the current parent controller is the leader. It will perform the following actions for each system store of each cluster: 1. Pre-filter: check that system stores are created and versions are not stale. 2. Health check: run the configured SystemStoreHealthChecker (heartbeat-based by default, but pluggable). 3. Repair: for any store that fails (1) or (2), run an empty push to repair it. It emits metrics to indicate bad system store counts per cluster and how many stores are not fixable by the task.

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.logging.log4j.Logger	LOGGER
static final String	SYSTEM_STORE_REPAIR_JOB_PREFIX

Constructor Summary

Constructors

Constructor	Description
SystemStoreRepairTask(VeniceParentHelixAdmin parentAdmin, Map<String,SystemStoreHealthCheckStats> clusterToSystemStoreHealthCheckStatsMap, int versionRefreshThresholdInDays, int maxRepairPerRound, AtomicBoolean isRunning, SystemStoreHealthChecker healthChecker)

Method Summary

Modifier and Type	Method	Description
void	run()

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

public static final org.apache.logging.log4j.Logger LOGGER

SYSTEM_STORE_REPAIR_JOB_PREFIX

public static final String SYSTEM_STORE_REPAIR_JOB_PREFIX

See Also:

• Constant Field Values

Constructor Details

SystemStoreRepairTask

public SystemStoreRepairTask(VeniceParentHelixAdmin parentAdmin,
 Map<String,SystemStoreHealthCheckStats> clusterToSystemStoreHealthCheckStatsMap,
 int versionRefreshThresholdInDays,
 int maxRepairPerRound,
 AtomicBoolean isRunning,
 SystemStoreHealthChecker healthChecker)

Method Details

run

public void run()

Specified by:

run in interface Runnable