Package org.apache.hadoop.hbase.master.procedure

Class RSProcedureDispatcher.ExecuteProceduresRemoteCall

java.lang.Object

org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.ExecuteProceduresRemoteCall

All Implemented Interfaces:

Runnable, RSProcedureDispatcher.RemoteProcedureResolver

Direct Known Subclasses:

RSProcedureDispatcher.DeadRSRemoteCall

Enclosing class:

RSProcedureDispatcher

protected class RSProcedureDispatcher.ExecuteProceduresRemoteCall
extends Object
implements RSProcedureDispatcher.RemoteProcedureResolver, Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	DEFAULT_RS_REMOTE_PROC_RETRY_LIMIT	The default retry limit.
private static final int	DEFAULT_RS_RPC_RETRY_INTERVAL
private final int	failFastRetryLimit
private long	maxWaitTime
private int	numberOfAttemptsSoFar
private final Set<RemoteProcedureDispatcher.RemoteProcedure>	remoteProcedures
private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest.Builder	request
private static final String	RS_REMOTE_PROC_FAIL_FAST_LIMIT	Config to determine the retry limit while executing remote regionserver procedure.
private static final String	RS_RPC_RETRY_INTERVAL_CONF_KEY
private final long	rsRpcRetryInterval
private final ServerName	serverName

Constructor Summary

Constructors

Constructor	Description
ExecuteProceduresRemoteCall(ServerName serverName, Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures)

Method Summary

Modifier and Type	Method	Description
void	dispatchCloseRequests(MasterProcedureEnv env, List<RSProcedureDispatcher.RegionCloseOperation> operations)
void	dispatchOpenRequests(MasterProcedureEnv env, List<RSProcedureDispatcher.RegionOpenOperation> operations)
void	dispatchServerOperations(MasterProcedureEnv env, List<RSProcedureDispatcher.ServerOperation> operations)
private long	getMaxWaitTime()
private AsyncRegionServerAdmin	getRsAdmin()
protected final ServerName	getServerName()
private boolean	isErrorTypeFailFast(IOException e)	Returns true if the error type can allow fail-fast.
private boolean	isNetworkError(IOException e)	Returns true if the error or its cause indicates a network connection issue.
private boolean	isSaslError(IOException e)
protected final void	remoteCallFailed(MasterProcedureEnv env, IOException e)
void	run()
private boolean	scheduleForRetry(IOException e)
protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse	sendRequest(ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest request)
private boolean	unableToConnectToServer(IOException e)	The category of exceptions where we can ensure that the request has not yet been received and/or processed by the target regionserver yet and hence we can determine whether it is safe to choose different regionserver as the target.
private IOException	unwrapException(IOException e)

Methods inherited from class java.lang.Object

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

Field Details

serverName

private final ServerName serverName

remoteProcedures

private final Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures

numberOfAttemptsSoFar

private int numberOfAttemptsSoFar

maxWaitTime

private long maxWaitTime

rsRpcRetryInterval

private final long rsRpcRetryInterval

RS_RPC_RETRY_INTERVAL_CONF_KEY

private static final String RS_RPC_RETRY_INTERVAL_CONF_KEY

See Also:

• Constant Field Values

DEFAULT_RS_RPC_RETRY_INTERVAL

private static final int DEFAULT_RS_RPC_RETRY_INTERVAL

See Also:

• Constant Field Values

RS_REMOTE_PROC_FAIL_FAST_LIMIT

private static final String RS_REMOTE_PROC_FAIL_FAST_LIMIT

Config to determine the retry limit while executing remote regionserver procedure. This retry limit applies to only specific errors. These errors could potentially get the remote procedure stuck for several minutes unless the retry limit is applied.

See Also:

• Constant Field Values

DEFAULT_RS_REMOTE_PROC_RETRY_LIMIT

private static final int DEFAULT_RS_REMOTE_PROC_RETRY_LIMIT

The default retry limit. Waiting for more than 5 attempts is not going to help much for genuine connectivity errors. Therefore, consider fail-fast after 5 retries. Value = 5

See Also:

• Constant Field Values

failFastRetryLimit

private final int failFastRetryLimit

request

private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest.Builder request

Constructor Details

ExecuteProceduresRemoteCall

public ExecuteProceduresRemoteCall(ServerName serverName,
 Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures)

Method Details

getRsAdmin

private AsyncRegionServerAdmin getRsAdmin()
                                   throws IOException

Throws:

IOException

getServerName

protected final ServerName getServerName()

scheduleForRetry

private boolean scheduleForRetry(IOException e)

unableToConnectToServer

private boolean unableToConnectToServer(IOException e)

The category of exceptions where we can ensure that the request has not yet been received and/or processed by the target regionserver yet and hence we can determine whether it is safe to choose different regionserver as the target.

Parameters:

e - IOException thrown by the underlying rpc framework.

Returns:

true if the exception belongs to the category where the regionserver has not yet received the request yet.

isSaslError

private boolean isSaslError(IOException e)

isNetworkError

private boolean isNetworkError(IOException e)

Returns true if the error or its cause indicates a network connection issue.

Parameters:

e - IOException thrown by the underlying rpc framework.

Returns:

True if the error or its cause indicates a network connection issue.

isErrorTypeFailFast

private boolean isErrorTypeFailFast(IOException e)

Returns true if the error type can allow fail-fast.

Parameters:

e - IOException thrown by the underlying rpc framework.

Returns:

True if the error type can allow fail-fast.

getMaxWaitTime

private long getMaxWaitTime()

unwrapException

private IOException unwrapException(IOException e)

run

public void run()

Specified by:

run in interface Runnable

dispatchOpenRequests

public void dispatchOpenRequests(MasterProcedureEnv env,
 List<RSProcedureDispatcher.RegionOpenOperation> operations)

Specified by:

dispatchOpenRequests in interface RSProcedureDispatcher.RemoteProcedureResolver

dispatchCloseRequests

public void dispatchCloseRequests(MasterProcedureEnv env,
 List<RSProcedureDispatcher.RegionCloseOperation> operations)

Specified by:

dispatchCloseRequests in interface RSProcedureDispatcher.RemoteProcedureResolver

dispatchServerOperations

public void dispatchServerOperations(MasterProcedureEnv env,
 List<RSProcedureDispatcher.ServerOperation> operations)

Specified by:

dispatchServerOperations in interface RSProcedureDispatcher.RemoteProcedureResolver

sendRequest

protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse sendRequest(ServerName serverName,
 org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest request)
                                                                                                       throws IOException

Throws:

IOException

remoteCallFailed

protected final void remoteCallFailed(MasterProcedureEnv env,
 IOException e)