To make 'local' mode more responsive, make values such as
- * hbase.regionserver.msginterval,
- * hbase.master.meta.thread.rescanfrequency, and
- * hbase.server.thread.wakefrequency a second or less.
*/
public class LocalHBaseCluster {
static final Log LOG = LogFactory.getLog(LocalHBaseCluster.class);
Index: src/main/java/org/apache/hadoop/hbase/master/ServerManager.java
===================================================================
--- src/main/java/org/apache/hadoop/hbase/master/ServerManager.java (revision 991583)
+++ src/main/java/org/apache/hadoop/hbase/master/ServerManager.java (working copy)
@@ -126,16 +126,14 @@
this.master = master;
this.services = services;
Configuration c = master.getConfiguration();
- int metaRescanInterval = c.getInt("hbase.master.meta.thread.rescanfrequency",
- 60 * 1000);
+ int monitorInterval = c.getInt("hbase.master.monitor.interval", 60 * 1000);
this.minimumServerCount = c.getInt("hbase.regions.server.count.min", 1);
this.metrics = new MasterMetrics(master.getServerName());
- this.serverMonitorThread = new ServerMonitor(metaRescanInterval, master);
+ this.serverMonitorThread = new ServerMonitor(monitorInterval, master);
String n = Thread.currentThread().getName();
Threads.setDaemonThreadRunning(this.serverMonitorThread,
n + ".serverMonitor");
- this.logCleaner = new LogCleaner(
- c.getInt("hbase.master.meta.thread.rescanfrequency",60 * 1000),
+ this.logCleaner = new LogCleaner(c.getInt("hbase.master.cleaner.interval", 60 * 1000),
master, c, this.services.getMasterFileSystem().getFileSystem(),
this.services.getMasterFileSystem().getOldLogDir());
Threads.setDaemonThreadRunning(logCleaner,
@@ -580,4 +578,4 @@
public boolean isClusterShutdown() {
return this.clusterShutdown;
}
-}
\ No newline at end of file
+}
Index: src/main/java/org/apache/hadoop/hbase/master/HMaster.java
===================================================================
--- src/main/java/org/apache/hadoop/hbase/master/HMaster.java (revision 991583)
+++ src/main/java/org/apache/hadoop/hbase/master/HMaster.java (working copy)
@@ -467,7 +467,8 @@
private static Chore getAndStartBalancerChore(final HMaster master) {
String name = master.getServerName() + "-balancerChore";
- int period = master.getConfiguration().getInt("hbase.balancer.period", 600000);
+ int period = master.getConfiguration().
+ getInt("hbase.master.balancer.period", 3000000);
// Start up the load balancer chore
Chore chore = new Chore(name, period, master) {
@Override
Index: src/main/resources/hbase-default.xml
===================================================================
--- src/main/resources/hbase-default.xml (revision 991583)
+++ src/main/resources/hbase-default.xml (working copy)
@@ -72,13 +72,6 @@