diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ActiveMasterManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ActiveMasterManager.java index c69f671..d331626 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ActiveMasterManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ActiveMasterManager.java @@ -56,7 +56,7 @@ public class ActiveMasterManager extends ZooKeeperListener { final AtomicBoolean clusterShutDown = new AtomicBoolean(false); private final ServerName sn; - private final int infoPort; + private int infoPort; private final Server master; /** @@ -72,6 +72,10 @@ public class ActiveMasterManager extends ZooKeeperListener { this.master = master; } + void setInfoPort(int infoPort) { + this.infoPort = infoPort; + } + @Override public void nodeCreated(String path) { handle(path); diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java index 0bb02f2..38557ca 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java @@ -382,6 +382,7 @@ public class HMaster extends HRegionServer implements MasterServices, Server { } startActiveMasterManager(); putUpJettyServer(); + activeMasterManager.setInfoPort(masterInfoPort); } private void putUpJettyServer() throws IOException {