alluxio.worker.block

Class SpecificMasterBlockSync

java.lang.Object

alluxio.worker.block.SpecificMasterBlockSync

All Implemented Interfaces:

HeartbeatExecutor, Closeable, AutoCloseable

Direct Known Subclasses:

TestSpecificMasterBlockSync

@NotThreadSafe
public class SpecificMasterBlockSync
extends Object
implements HeartbeatExecutor, Closeable

The block master sync thread when workers are registered to all masters. With respect to behaviors, this implementation differs from BlockMasterSync in: 1. The registration takes place asynchronously and the caller can poll the registration state. We need to make the process async because when standby master read is enabled, workers have to register to all masters and these registrations can happen concurrently to speed up the process. 2. A registration failure doesn't throw a fatal exception. Instead, it retries endlessly. This is because a standby master registration failure should be a soft failure and can be retried later.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SpecificMasterBlockSync.Metrics Metrics.

Constructor Summary

Constructors

Constructor and Description
SpecificMasterBlockSync(BlockWorker blockWorker, BlockMasterClient masterClient, BlockHeartbeatReporter heartbeatReporter) Creates a new instance of SpecificMasterBlockSync.

Method Summary

Modifier and Type	Method and Description
protected void	beforeHeartbeat()
void	close() Cleans up any resources used by the heartbeat executor.
void	heartbeat() Implements the heartbeat logic.
boolean	isRegistered()
protected void	registerWithMasterInternal()

Methods inherited from class java.lang.Object

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

Constructor Detail

SpecificMasterBlockSync

public SpecificMasterBlockSync(BlockWorker blockWorker,
                               BlockMasterClient masterClient,
                               BlockHeartbeatReporter heartbeatReporter)
                        throws IOException

Creates a new instance of SpecificMasterBlockSync.

Parameters:

blockWorker - the BlockWorker this syncer is updating to

masterClient - the block master client

heartbeatReporter - the heartbeat reporter

Throws:

IOException

Method Detail

registerWithMasterInternal

protected void registerWithMasterInternal()
                                   throws IOException,
                                          FailedToAcquireRegisterLeaseException

Throws:

IOException

FailedToAcquireRegisterLeaseException

heartbeat

public void heartbeat()
               throws InterruptedException

Description copied from interface: HeartbeatExecutor

Implements the heartbeat logic.

Specified by:

heartbeat in interface HeartbeatExecutor

Throws:

InterruptedException - if the thread is interrupted

beforeHeartbeat

protected void beforeHeartbeat()

close

public void close()

Description copied from interface: HeartbeatExecutor

Cleans up any resources used by the heartbeat executor.

Specified by:

close in interface HeartbeatExecutor

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

isRegistered

public boolean isRegistered()

Returns:

if the worker has registered with the master successfully