Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-21237 Use CompatRemoteProcedureResolver to dispatch open/close region requests to RS

This commit is contained in:
Allan Yang 2018-09-28 09:41:31 +08:00
parent eb27251265
commit 0290f57c3a
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java
View File

@ -109,16 +109,12 @@ public class RSProcedureDispatcher
protected void remoteDispatch(final ServerName serverName, protected void remoteDispatch(final ServerName serverName,
final Set<RemoteProcedure> remoteProcedures) { final Set<RemoteProcedure> remoteProcedures) {
final int rsVersion = master.getServerManager().getVersionNumber(serverName); final int rsVersion = master.getServerManager().getVersionNumber(serverName);
if (rsVersion >= RS_VERSION_WITH_EXEC_PROCS) { if (rsVersion == 0 && !master.getServerManager().isServerOnline(serverName)) {
LOG.trace("Using procedure batch rpc execution for serverName={} version={}", serverName,
rsVersion);
submitTask(new ExecuteProceduresRemoteCall(serverName, remoteProcedures));
} else if (rsVersion == 0 && !master.getServerManager().isServerOnline(serverName)) {
submitTask(new DeadRSRemoteCall(serverName, remoteProcedures)); submitTask(new DeadRSRemoteCall(serverName, remoteProcedures));
} else { } else {
LOG.info(String.format( // See HBASE-21237, fallback to CompatRemoteProcedureResolver for now. Since
"Fallback to compat rpc execution for serverName=%s version=%s", // ExecuteProceduresRemoteCall will group all the open/close requests. If one
serverName, rsVersion)); // fails, master will regard all the requests as failure and then cause some trouble.
submitTask(new CompatRemoteProcedureResolver(serverName, remoteProcedures)); submitTask(new CompatRemoteProcedureResolver(serverName, remoteProcedures));
} }
} }