Package com.linkedin.venice.pushmonitor

Class LeakedPushStatusCleanUpService

java.lang.Object

com.linkedin.venice.service.AbstractVeniceService

com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService

All Implemented Interfaces:

Closeable, AutoCloseable

public class LeakedPushStatusCleanUpService
extends AbstractVeniceService

LeakedPushStatusCleanUpService will wake up regularly (interval is determined by controller config ConfigKeys.LEAKED_PUSH_STATUS_CLEAN_UP_SERVICE_SLEEP_INTERVAL_MS), get all existing push status ZNodes on Zookeeper that belong to the specified cluster, without scanning through the replica statuses, find all leaked push status and delete them on Zookeeper. The life cycle of LeakedPushStatusCleanUpService matches the life cycle of HelixVeniceClusterResources, meaning that there is one clean up service for each cluster, and it's built when the controller is promoted to leader role for the cluster. The clean up service is needed because push job killing in server nodes is asynchronous, it's possible that servers write push status after controllers think they have cleaned up the push status.

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.venice.service.AbstractVeniceService

AbstractVeniceService.ServiceState

Field Summary

Fields inherited from class com.linkedin.venice.service.AbstractVeniceService

logger, serviceState

Constructor Summary

Constructors

Constructor	Description
LeakedPushStatusCleanUpService(String clusterName, OfflinePushAccessor offlinePushAccessor, ReadOnlyStoreRepository metadataRepository, StoreCleaner storeCleaner, AggPushStatusCleanUpStats aggPushStatusCleanUpStats, long sleepIntervalInMs, long leakedResourceAllowedLingerTimeInMs)

Method Summary

Modifier and Type	Method	Description
boolean	startInner()
void	stopInner()

Methods inherited from class com.linkedin.venice.service.AbstractVeniceService

close, getName, isRunning, start, stop

Methods inherited from class java.lang.Object

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

Constructor Details

LeakedPushStatusCleanUpService

public LeakedPushStatusCleanUpService(String clusterName,
 OfflinePushAccessor offlinePushAccessor,
 ReadOnlyStoreRepository metadataRepository,
 StoreCleaner storeCleaner,
 AggPushStatusCleanUpStats aggPushStatusCleanUpStats,
 long sleepIntervalInMs,
 long leakedResourceAllowedLingerTimeInMs)

Method Details

startInner

public boolean startInner()
                   throws Exception

Specified by:

startInner in class AbstractVeniceService

Returns:

true if the service is completely started, false if it is still starting asynchronously (in this case, it is the implementer's responsibility to set AbstractVeniceService.serviceState to AbstractVeniceService.ServiceState.STARTED upon completion of the async work).

Throws:

Exception

stopInner

public void stopInner()
               throws Exception

Specified by:

stopInner in class AbstractVeniceService

Throws:

Exception