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

HBASE-18104 AMv2: Enabled aggregation of RPCs 

Unit test (TestAssignmentManager) uses mock which always aggregates. So added trace level log message and verified manually on a single node cluster.

Signed-off-by: Michael Stack <stack@apache.org>
This commit is contained in:
Umesh Agashe 2017-06-15 14:15:33 -07:00 committed by Michael Stack
parent b02d3d9ed5
commit d49208b056
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -61,7 +61,7 @@ public class RSProcedureDispatcher
"hbase.regionserver.rpc.startup.waittime"; "hbase.regionserver.rpc.startup.waittime";
private static final int DEFAULT_RS_RPC_STARTUP_WAIT_TIME = 60000; private static final int DEFAULT_RS_RPC_STARTUP_WAIT_TIME = 60000;
private static final int RS_VERSION_WITH_EXEC_PROCS = 0x0201000; // 2.1 private static final int RS_VERSION_WITH_EXEC_PROCS = 0x0200000; // 2.0
protected final MasterServices master; protected final MasterServices master;
protected final long rsStartupWaitTime; protected final long rsStartupWaitTime;
@ -259,6 +259,9 @@ public class RSProcedureDispatcher
final MasterProcedureEnv env = master.getMasterProcedureExecutor().getEnvironment(); final MasterProcedureEnv env = master.getMasterProcedureExecutor().getEnvironment();
request = ExecuteProceduresRequest.newBuilder(); request = ExecuteProceduresRequest.newBuilder();
if (LOG.isTraceEnabled()) {
LOG.trace("Building request with operations count=" + operations.size());
}
splitAndResolveOperation(getServerName(), operations, this); splitAndResolveOperation(getServerName(), operations, this);
try { try {