From fa93c0f59a586e73c8652397069442e3cbbbd53a Mon Sep 17 00:00:00 2001 From: Umesh Agashe Date: Thu, 15 Jun 2017 14:15:33 -0700 Subject: [PATCH] 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 --- .../hadoop/hbase/master/procedure/RSProcedureDispatcher.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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 887e272bca0..eda1128a2aa 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 {