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 cluster which current parent controller is the leader controller. It will perform the following action for each system store of each cluster: 1. Check system store is created / has current version. 2. Send heartbeat to system store and check if heartbeat is received. 3. If system store failed any of the check in (1) / (2), it will try to run empty push to repair the system store, until maximum retry of repair is reached. It will emit 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 maxRepairRetry, int heartbeatWaitTimeSeconds, AtomicBoolean isRunning)

Method Summary

Modifier and Type	Method	Description
SystemStoreHealthCheckStats	getClusterSystemStoreHealthCheckStats(String clusterName)
Map<String,ControllerClient>	getControllerClientMap(String clusterName)
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 maxRepairRetry,
 int heartbeatWaitTimeSeconds,
 AtomicBoolean isRunning)

Method Details

run

public void run()

Specified by:

run in interface Runnable

getControllerClientMap

public Map<String,ControllerClient> getControllerClientMap(String clusterName)

getClusterSystemStoreHealthCheckStats

public SystemStoreHealthCheckStats getClusterSystemStoreHealthCheckStats(String clusterName)