You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2016/08/12 04:51:44 UTC
hbase git commit: HBASE-16402 RegionServerCoprocessorHost should be
initialized before RpcServer starts (Guanghao Zhang)
Repository: hbase
Updated Branches:
refs/heads/0.98 510d11769 -> 8168667f3
HBASE-16402 RegionServerCoprocessorHost should be initialized before RpcServer starts (Guanghao Zhang)
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/8168667f
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8168667f
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8168667f
Branch: refs/heads/0.98
Commit: 8168667f3aeb08bce70d9812bed40ecf9bd02bd1
Parents: 510d117
Author: Andrew Purtell <ap...@apache.org>
Authored: Thu Aug 11 17:00:46 2016 -0700
Committer: Andrew Purtell <ap...@apache.org>
Committed: Thu Aug 11 21:51:29 2016 -0700
----------------------------------------------------------------------
.../org/apache/hadoop/hbase/regionserver/HRegionServer.java | 9 ++++-----
1 file changed, 4 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/8168667f/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
index 7fff722..1d8116f 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
@@ -905,11 +905,6 @@ public class HRegionServer implements ClientProtos.ClientService.BlockingInterfa
}
}
- // Initialize the RegionServerCoprocessorHost now that our ephemeral
- // node was created by reportForDuty, in case any coprocessors want
- // to use ZooKeeper
- this.rsHost = new RegionServerCoprocessorHost(this, this.conf);
-
if (!this.stopped && isHealthy()){
// start the snapshot handler and other procedure handlers,
// since the server is ready to run
@@ -1339,6 +1334,10 @@ public class HRegionServer implements ClientProtos.ClientService.BlockingInterfa
// Set our ephemeral znode up in zookeeper now we have a name.
createMyEphemeralNode();
+ // Initialize the RegionServerCoprocessorHost now that our ephemeral
+ // node was created, in case any coprocessors want to use ZooKeeper
+ this.rsHost = new RegionServerCoprocessorHost(this, this.conf);
+
// Save it in a file, this will allow to see if we crash
ZNodeClearer.writeMyEphemeralNodeOnDisk(getMyEphemeralNodePath());