Repository: hbase Updated Branches: refs/heads/branch-2 5db63014b -> fa93c0f59
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 <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/fa93c0f5 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/fa93c0f5 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/fa93c0f5 Branch: refs/heads/branch-2 Commit: fa93c0f59a586e73c8652397069442e3cbbbd53a Parents: 5db6301 Author: Umesh Agashe <[email protected]> Authored: Thu Jun 15 14:15:33 2017 -0700 Committer: Michael Stack <[email protected]> Committed: Fri Jun 16 23:54:11 2017 -0700 ---------------------------------------------------------------------- .../hadoop/hbase/master/procedure/RSProcedureDispatcher.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/fa93c0f5/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java index 887e272..eda1128 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java @@ -61,7 +61,7 @@ public class RSProcedureDispatcher "hbase.regionserver.rpc.startup.waittime"; 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 long rsStartupWaitTime; @@ -259,6 +259,9 @@ public class RSProcedureDispatcher final MasterProcedureEnv env = master.getMasterProcedureExecutor().getEnvironment(); request = ExecuteProceduresRequest.newBuilder(); + if (LOG.isTraceEnabled()) { + LOG.trace("Building request with operations count=" + operations.size()); + } splitAndResolveOperation(getServerName(), operations, this); try {
