diff --git a/hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/master/MasterStatusTmpl.jamon b/hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/master/MasterStatusTmpl.jamon index 58032976c7..43f1f7aec8 100644 --- a/hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/master/MasterStatusTmpl.jamon +++ b/hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/master/MasterStatusTmpl.jamon @@ -55,6 +55,11 @@ org.apache.hadoop.hbase.protobuf.ProtobufUtil; org.apache.hadoop.hbase.security.visibility.VisibilityConstants; org.apache.hadoop.hbase.security.access.AccessControlLists; org.apache.hadoop.hbase.quotas.QuotaUtil; +org.apache.hadoop.hbase.replication.ReplicationPeerConfig; +org.apache.hadoop.hbase.client.replication.ReplicationAdmin; +org.apache.hadoop.hbase.replication.ReplicationException; +org.apache.hadoop.hbase.HBaseConfiguration; +org.apache.hadoop.conf.Configuration; <%if format.equals("json") %> @@ -239,6 +244,66 @@ AssignmentManager assignmentManager = master.getAssignmentManager();
<& ../common/TaskMonitorTmpl; filter = filter &>
+ <%java> + Configuration conf = master.getConfiguration(); + ReplicationAdmin replAdmin = new ReplicationAdmin(conf); + Map peers = replAdmin.listPeerConfigs(); + + +
+

Replication Peers

+ + + + + + + + + + + <%for Map.Entry peerEntry : peers.entrySet() %> + <%java> + String peerID = peerEntry.getKey(); + String clusterKey = peerEntry.getValue().getClusterKey(); + String replicationEndpointImpl = peerEntry.getValue().getReplicationEndpointImpl(); + Map peerConfiguration = peerEntry.getValue().getConfiguration(); + String state = ""; + boolean isEnabled = true; + try { + isEnabled = replAdmin.getPeerState(peerID); + state = (isEnabled == true) ? "ENABLED" : "DISABLED"; + } + catch(ReplicationException repExp){ + state = "N/A"; + } + + + + + + + + <%java> + String mapStr = peerConfiguration.toString(); //encloses key=value pairs in {} + int start = mapStr.indexOf('{'); + int end = mapStr.indexOf('}'); + String strToShow = mapStr.substring(start+1,end); //remove {} + + + + + + + + + + + + + +
Peer IDCluster KeyStatusReplicationEndpointImplConfiguration
<% peerID %><% clusterKey %><% state %><% replicationEndpointImpl %><% strToShow %>
Total:<% peers.size() %>
+

Software Attributes