hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From st...@apache.org
Subject hbase git commit: HBASE-18104 AMv2: Enabled aggregation of RPCs
Date Sat, 17 Jun 2017 06:53:49 GMT
Repository: hbase
Updated Branches:
  refs/heads/master b02d3d9ed -> d49208b05


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>


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/d49208b0
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/d49208b0
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/d49208b0

Branch: refs/heads/master
Commit: d49208b0562a2325a89b8b27b837b4dc131068c1
Parents: b02d3d9
Author: Umesh Agashe <uagashe@cloudera.com>
Authored: Thu Jun 15 14:15:33 2017 -0700
Committer: Michael Stack <stack@apache.org>
Committed: Fri Jun 16 23:53:39 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/d49208b0/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 {


Mime
View raw message