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

HBASE-772 Up default lease period from 60 to 120 seconds 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@679560 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2008-07-24 22:01:05 +00:00
parent bc76ab38a5
commit 3b544ee93c
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/java/org/apache/hadoop/hbase/master/HMaster.java
View File

@ -214,8 +214,8 @@ public class HMaster extends Thread implements HConstants, HMasterInterface,
this.numRetries = conf.getInt("hbase.client.retries.number", 2); this.numRetries = conf.getInt("hbase.client.retries.number", 2);
this.maxRegionOpenTime = this.maxRegionOpenTime =
conf.getLong("hbase.hbasemaster.maxregionopen", 60 * 1000); conf.getLong("hbase.hbasemaster.maxregionopen", 120 * 1000);
this.leaseTimeout = conf.getInt("hbase.master.lease.period", 30 * 1000); this.leaseTimeout = conf.getInt("hbase.master.lease.period", 120 * 1000);
this.server = HbaseRPC.getServer(this, address.getBindAddress(), this.server = HbaseRPC.getServer(this, address.getBindAddress(),
address.getPort(), conf.getInt("hbase.regionserver.handler.count", 10), address.getPort(), conf.getInt("hbase.regionserver.handler.count", 10),

2
src/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
View File

@ -234,7 +234,7 @@ public class HRegionServer implements HConstants, HRegionInterface, Runnable {
this.threadWakeFrequency = conf.getInt(THREAD_WAKE_FREQUENCY, 10 * 1000); this.threadWakeFrequency = conf.getInt(THREAD_WAKE_FREQUENCY, 10 * 1000);
this.msgInterval = conf.getInt("hbase.regionserver.msginterval", 3 * 1000); this.msgInterval = conf.getInt("hbase.regionserver.msginterval", 3 * 1000);
this.serverLeaseTimeout = this.serverLeaseTimeout =
conf.getInt("hbase.master.lease.period", 30 * 1000); conf.getInt("hbase.master.lease.period", 120 * 1000);
// Cache flushing thread. // Cache flushing thread.
this.cacheFlusher = new Flusher(conf, this); this.cacheFlusher = new Flusher(conf, this);