You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2018/10/26 13:45:55 UTC
hbase git commit: HBASE-21391 RefreshPeerProcedure should also wait
master initialized before executing
Repository: hbase
Updated Branches:
refs/heads/master 385e39810 -> 0ab7c3a18
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/0ab7c3a1
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/0ab7c3a1
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/0ab7c3a1
Branch: refs/heads/master
Commit: 0ab7c3a18906fcf33af38da29c211ac7fcb46492
Parents: 385e398
Author: Duo Zhang <zh...@apache.org>
Authored: Fri Oct 26 14:31:49 2018 +0800
Committer: zhangduo <zh...@apache.org>
Committed: Fri Oct 26 21:44:56 2018 +0800
----------------------------------------------------------------------
.../hadoop/hbase/master/replication/RefreshPeerProcedure.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/0ab7c3a1/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 8502edf..2f43ae9 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
@@ -206,6 +206,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))