Package com.linkedin.venice.controller

Class ErrorPartitionResetTask

java.lang.Object

com.linkedin.venice.controller.ErrorPartitionResetTask

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public class ErrorPartitionResetTask
extends Object
implements Runnable, Closeable

A task that iterates over store version resources and reset error partitions if they meet the following criteria:

1. The store version resource is the current version.
2. The error partition only has exactly one error replica.
3. For L/F model, using EV to check error replicas misses internal error replica states. For example, a replica is shown Leader in EV but actually ERROR in offline push status.

Constructor Summary

Constructors

Constructor	Description
ErrorPartitionResetTask(String clusterName, HelixAdminClient helixAdminClient, ReadOnlyStoreRepository readOnlyStoreRepository, HelixExternalViewRepository routingDataRepository, PushMonitor pushMonitor, io.tehuti.metrics.MetricsRepository metricsRepository, int errorPartitionAutoResetLimit, long processingCycleDelayMs)

Method Summary

Modifier and Type	Method	Description
void	close()	Cause ErrorPartitionResetTask to stop executing.
void	run()

Methods inherited from class java.lang.Object

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

Constructor Details

ErrorPartitionResetTask

public ErrorPartitionResetTask(String clusterName,
 HelixAdminClient helixAdminClient,
 ReadOnlyStoreRepository readOnlyStoreRepository,
 HelixExternalViewRepository routingDataRepository,
 PushMonitor pushMonitor,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 int errorPartitionAutoResetLimit,
 long processingCycleDelayMs)

Method Details

run

public void run()

Specified by:

run in interface Runnable

close

public void close()

Cause ErrorPartitionResetTask to stop executing.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable