Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-14976 Add RPC call queues to the web ui (Pallavi Adusumilli)

This commit is contained in:
Mikhail Antonov 2015-12-19 12:44:30 -08:00
parent 6564cae667
commit 79baaeb540
3 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/regionserver/RSStatusTmpl.jamon
View File

@ -104,7 +104,8 @@ org.apache.hadoop.hbase.zookeeper.MasterAddressTracker;
<section> <section>
<h2>Server Metrics</h2> <h2>Server Metrics</h2>
<& ServerMetricsTmpl; mWrap = regionServer.getRegionServerMetrics().getRegionServerWrapper(); &> <& ServerMetricsTmpl; mWrap = regionServer.getRegionServerMetrics().getRegionServerWrapper();
mServerWrap = regionServer.getRpcServer().getMetrics().getHBaseServerWrapper(); &>
</section> </section>
<section> <section>

8
hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/regionserver/ServerMetricsTmpl.jamon
View File

@ -18,10 +18,12 @@ limitations under the License.
</%doc> </%doc>
<%args> <%args>
MetricsRegionServerWrapper mWrap; MetricsRegionServerWrapper mWrap;
MetricsHBaseServerWrapper mServerWrap;
</%args> </%args>
<%import> <%import>
java.util.*; java.util.*;
org.apache.hadoop.hbase.regionserver.HRegionServer; org.apache.hadoop.hbase.regionserver.HRegionServer;
org.apache.hadoop.hbase.ipc.MetricsHBaseServerWrapper;
org.apache.hadoop.hbase.regionserver.MetricsRegionServerWrapper; org.apache.hadoop.hbase.regionserver.MetricsRegionServerWrapper;
org.apache.hadoop.hbase.util.Bytes; org.apache.hadoop.hbase.util.Bytes;
org.apache.hadoop.hbase.HRegionInfo; org.apache.hadoop.hbase.HRegionInfo;
@ -61,7 +63,7 @@ java.lang.management.ManagementFactory;
<& storeStats; mWrap = mWrap &> <& storeStats; mWrap = mWrap &>
</div> </div>
<div class="tab-pane" id="tab_queueStats"> <div class="tab-pane" id="tab_queueStats">
<& queueStats; mWrap = mWrap &> <& queueStats; mWrap = mWrap; mServerWrap = mServerWrap; &>
</div> </div>
</div> </div>
</div> </div>
@ -184,16 +186,20 @@ MetricsRegionServerWrapper mWrap;
<%def queueStats> <%def queueStats>
<%args> <%args>
MetricsRegionServerWrapper mWrap; MetricsRegionServerWrapper mWrap;
MetricsHBaseServerWrapper mServerWrap;
</%args> </%args>
<table class="table table-striped"> <table class="table table-striped">
<tr> <tr>
<th>Compaction Queue Size</th> <th>Compaction Queue Size</th>
<th>Flush Queue Size</th> <th>Flush Queue Size</th>
<th>Call Queue Size (bytes)</th>
</tr> </tr>
<tr> <tr>
<td><% mWrap.getCompactionQueueSize() %></td> <td><% mWrap.getCompactionQueueSize() %></td>
<td><% mWrap.getFlushQueueSize() %></td> <td><% mWrap.getFlushQueueSize() %></td>
<td><% StringUtils.TraditionalBinaryPrefix.long2String(mServerWrap.getTotalQueueSize(),
"", 1) %></td>
</tr> </tr>
</table> </table>
</%def> </%def>

6
hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/MetricsHBaseServer.java
View File

@ -32,8 +32,10 @@ import org.apache.hadoop.hbase.exceptions.RegionMovedException;
@InterfaceAudience.Private @InterfaceAudience.Private
public class MetricsHBaseServer { public class MetricsHBaseServer {
private MetricsHBaseServerSource source; private MetricsHBaseServerSource source;
private MetricsHBaseServerWrapper serverWrapper;
public MetricsHBaseServer(String serverName, MetricsHBaseServerWrapper wrapper) { public MetricsHBaseServer(String serverName, MetricsHBaseServerWrapper wrapper) {
serverWrapper = wrapper;
source = CompatibilitySingletonFactory.getInstance(MetricsHBaseServerSourceFactory.class) source = CompatibilitySingletonFactory.getInstance(MetricsHBaseServerSourceFactory.class)
.create(serverName, wrapper); .create(serverName, wrapper);
} }
@ -115,4 +117,8 @@ public class MetricsHBaseServer {
public MetricsHBaseServerSource getMetricsSource() { public MetricsHBaseServerSource getMetricsSource() {
return source; return source;
} }
public MetricsHBaseServerWrapper getHBaseServerWrapper() {
return serverWrapper;
}
} }