HBASE-4934 Display Master server and Regionserver start time on respective info servers
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1220304 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
fa03d03ddf
commit
d9c8e9954a
@ -111,6 +111,8 @@ org.apache.hadoop.hbase.HBaseConfiguration;
|
|||||||
</td>
|
</td>
|
||||||
<td>Coprocessors currently loaded loaded by the master</td>
|
<td>Coprocessors currently loaded loaded by the master</td>
|
||||||
</tr>
|
</tr>
|
||||||
|
<tr><td>HMaster Start Time</td><td><% new Date(master.getMasterStartTime()) %></td><td>Date stamp of when this HMaster was started</td></tr>
|
||||||
|
<tr><td>HMaster Active Time</td><td><% new Date(master.getMasterActiveTime()) %></td><td>Date stamp of when this HMaster became active</td></tr>
|
||||||
</table>
|
</table>
|
||||||
|
|
||||||
<& ../common/TaskMonitorTmpl; filter = filter &>
|
<& ../common/TaskMonitorTmpl; filter = filter &>
|
||||||
@ -202,7 +204,7 @@ org.apache.hadoop.hbase.HBaseConfiguration;
|
|||||||
</%java>
|
</%java>
|
||||||
|
|
||||||
<table>
|
<table>
|
||||||
<tr><th rowspan="<% servers.size() + 1%>"></th><th>ServerName</th><th>Load</th></tr>
|
<tr><th rowspan="<% servers.size() + 1%>"></th><th>ServerName</th><th>Start time</th><th>Load</th></tr>
|
||||||
<%java>
|
<%java>
|
||||||
ServerName [] serverNames = servers.toArray(new ServerName[servers.size()]);
|
ServerName [] serverNames = servers.toArray(new ServerName[servers.size()]);
|
||||||
Arrays.sort(serverNames);
|
Arrays.sort(serverNames);
|
||||||
@ -217,12 +219,13 @@ org.apache.hadoop.hbase.HBaseConfiguration;
|
|||||||
totalRegions += hsl.getNumberOfRegions();
|
totalRegions += hsl.getNumberOfRegions();
|
||||||
totalRequests += hsl.getNumberOfRequests();
|
totalRequests += hsl.getNumberOfRequests();
|
||||||
}
|
}
|
||||||
|
long startcode = serverName.getStartcode();
|
||||||
</%java>
|
</%java>
|
||||||
<tr><td><a href="<% url %>"><% serverName %></a></td></td><td><% loadStr %></td></tr>
|
<tr><td><a href="<% url %>"><% serverName %></a></td><td><% new Date(startcode) %></td><td><% loadStr %></td></tr>
|
||||||
<%java>
|
<%java>
|
||||||
}
|
}
|
||||||
</%java>
|
</%java>
|
||||||
<tr><th>Total: </th><td>servers: <% servers.size() %></td><td>requestsPerSecond=<% totalRequests %>, numberOfOnlineRegions=<% totalRegions %></td></tr>
|
<tr><th>Total: </th><td>servers: <% servers.size() %></td><td></td><td>requestsPerSecond=<% totalRequests %>, numberOfOnlineRegions=<% totalRegions %></td></tr>
|
||||||
</table>
|
</table>
|
||||||
|
|
||||||
<p>Load is requests per second and count of regions loaded</p>
|
<p>Load is requests per second and count of regions loaded</p>
|
||||||
|
@ -96,6 +96,7 @@ org.apache.hadoop.hbase.HBaseConfiguration;
|
|||||||
<% java.util.Arrays.toString(regionServer.getCoprocessors()) %>
|
<% java.util.Arrays.toString(regionServer.getCoprocessors()) %>
|
||||||
</td>
|
</td>
|
||||||
<td>Coprocessors currently loaded by this regionserver</td>
|
<td>Coprocessors currently loaded by this regionserver</td>
|
||||||
|
<tr><td>RS Start Time</td><td><% new Date(regionServer.getStartcode()) %></td><td>Date stamp of when this region server was started</td></tr>
|
||||||
</tr>
|
</tr>
|
||||||
</table>
|
</table>
|
||||||
|
|
||||||
|
@ -199,7 +199,10 @@ implements HMasterInterface, HMasterRegionInterface, MasterServices, Server {
|
|||||||
|
|
||||||
private volatile boolean loadBalancerRunning = false;
|
private volatile boolean loadBalancerRunning = false;
|
||||||
|
|
||||||
|
// Time stamps for when a hmaster was started and when it became active
|
||||||
|
private long masterStartTime;
|
||||||
|
private long masterActiveTime;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Initializes the HMaster. The steps are as follows:
|
* Initializes the HMaster. The steps are as follows:
|
||||||
* <p>
|
* <p>
|
||||||
@ -301,6 +304,7 @@ implements HMasterInterface, HMasterRegionInterface, MasterServices, Server {
|
|||||||
"(Also watching cluster state node)");
|
"(Also watching cluster state node)");
|
||||||
Thread.sleep(c.getInt("zookeeper.session.timeout", 180 * 1000));
|
Thread.sleep(c.getInt("zookeeper.session.timeout", 180 * 1000));
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -317,6 +321,7 @@ implements HMasterInterface, HMasterRegionInterface, MasterServices, Server {
|
|||||||
MonitoredTask startupStatus =
|
MonitoredTask startupStatus =
|
||||||
TaskMonitor.get().createStatus("Master startup");
|
TaskMonitor.get().createStatus("Master startup");
|
||||||
startupStatus.setDescription("Master startup");
|
startupStatus.setDescription("Master startup");
|
||||||
|
masterStartTime = System.currentTimeMillis();
|
||||||
try {
|
try {
|
||||||
/*
|
/*
|
||||||
* Block on becoming the active master.
|
* Block on becoming the active master.
|
||||||
@ -458,6 +463,7 @@ implements HMasterInterface, HMasterRegionInterface, MasterServices, Server {
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
status.setStatus("Initializing Master file system");
|
status.setStatus("Initializing Master file system");
|
||||||
|
this.masterActiveTime = System.currentTimeMillis();
|
||||||
// TODO: Do this using Dependency Injection, using PicoContainer, Guice or Spring.
|
// TODO: Do this using Dependency Injection, using PicoContainer, Guice or Spring.
|
||||||
this.fileSystemManager = new MasterFileSystem(this, this, metrics);
|
this.fileSystemManager = new MasterFileSystem(this, this, metrics);
|
||||||
|
|
||||||
@ -1353,6 +1359,20 @@ implements HMasterInterface, HMasterRegionInterface, MasterServices, Server {
|
|||||||
return CoprocessorHost.getLoadedCoprocessors().toString();
|
return CoprocessorHost.getLoadedCoprocessors().toString();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @return timestamp in millis when HMaster was started.
|
||||||
|
*/
|
||||||
|
public long getMasterStartTime() {
|
||||||
|
return masterStartTime;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @return timestamp in millis when HMaster became the active master.
|
||||||
|
*/
|
||||||
|
public long getMasterActiveTime() {
|
||||||
|
return masterActiveTime;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @return array of coprocessor SimpleNames.
|
* @return array of coprocessor SimpleNames.
|
||||||
*/
|
*/
|
||||||
|
@ -2970,6 +2970,13 @@ public class HRegionServer implements HRegionInterface, HBaseRPCErrorHandler,
|
|||||||
return this.requestCount;
|
return this.requestCount;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @return time stamp in millis of when this region server was started
|
||||||
|
*/
|
||||||
|
public long getStartcode() {
|
||||||
|
return this.startcode;
|
||||||
|
}
|
||||||
|
|
||||||
/** @return reference to FlushRequester */
|
/** @return reference to FlushRequester */
|
||||||
public FlushRequester getFlushRequester() {
|
public FlushRequester getFlushRequester() {
|
||||||
return this.cacheFlusher;
|
return this.cacheFlusher;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user