hbase-commits mailing list archives

Repository: hbase
Updated Branches:
  refs/heads/branch-2 3c8577554 -> 4ded55702


HBASE-21391 RefreshPeerProcedure should also wait master initialized before executing


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

Branch: refs/heads/branch-2
Commit: 4ded55702d89673a59180a3ce52d2bf43a9a52d5
Parents: 3c85775
Author: Duo Zhang <zhangduo@apache.org>
Authored: Fri Oct 26 14:31:49 2018 +0800
Committer: zhangduo <zhangduo@apache.org>
Committed: Fri Oct 26 21:45:03 2018 +0800

----------------------------------------------------------------------
 .../hadoop/hbase/master/replication/RefreshPeerProcedure.java   | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/4ded5570/hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/RefreshPeerProcedure.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/RefreshPeerProcedure.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/RefreshPeerProcedure.java
index 10e16e9..84349ea 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/RefreshPeerProcedure.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/RefreshPeerProcedure.java
@@ -193,6 +193,11 @@ public class RefreshPeerProcedure extends Procedure<MasterProcedureEnv>
   }
 
   @Override
+  protected boolean waitInitialized(MasterProcedureEnv env) {
+    return env.waitInitialized(this);
+  }
+
+  @Override
   protected void serializeStateData(ProcedureStateSerializer serializer) throws IOException
{
     serializer.serialize(
       RefreshPeerStateData.newBuilder().setPeerId(peerId).setType(toPeerModificationType(type))