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

HBASE-3813 Change RPC callQueue size from "handlerCount * MAX_QUEUE_SIZE_PER_HANDLER;" 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1099695 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2011-05-05 06:07:56 +00:00
parent 22600649d3
commit 8ffaac2003
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
CHANGES.txt
View File

@ -286,7 +286,9 @@ Release 0.90.3 - Unreleased
HBASE-2470 Add Scan.setTimeRange() support in Shell (Harsh J Chouraria)
HBASE-3805 Log RegionState that are processed too late in the master
HBASE-3695 Some improvements to Hbck to test the entire region chain in
Meta and provide better error reporting (Marc Limotte)
Meta and provide better error reporting (Marc Limotte)
HBASE-3813 Change RPC callQueue size from 'handlerCount *
MAX_QUEUE_SIZE_PER_HANDLER;'
TASKS
HBASE-3748 Add rolling of thrift/rest daemons to graceful_stop.sh script

6
src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java
View File

@ -89,7 +89,7 @@ public abstract class HBaseServer implements RpcServer {
/**
* How many calls/handler are allowed in the queue.
*/
private static final int MAX_QUEUE_SIZE_PER_HANDLER = 100;
private static final int DEFAULT_MAX_QUEUE_SIZE_PER_HANDLER = 10;
private static final String WARN_RESPONSE_SIZE =
"hbase.ipc.warn.response.size";
@ -1174,7 +1174,9 @@ public abstract class HBaseServer implements RpcServer {
this.handlerCount = handlerCount;
this.priorityHandlerCount = priorityHandlerCount;
this.socketSendBufferSize = 0;
this.maxQueueSize = handlerCount * MAX_QUEUE_SIZE_PER_HANDLER;
this.maxQueueSize =
this.conf.getInt("ipc.server.max.queue.size",
handlerCount * DEFAULT_MAX_QUEUE_SIZE_PER_HANDLER);
this.readThreads = conf.getInt(
"ipc.server.read.threadpool.size",
10);