You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2011/05/05 08:07:56 UTC
svn commit: r1099695 - in /hbase/trunk: CHANGES.txt
src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java
Author: stack
Date: Thu May 5 06:07:56 2011
New Revision: 1099695
URL: http://svn.apache.org/viewvc?rev=1099695&view=rev
Log:
HBASE-3813 Change RPC callQueue size from "handlerCount * MAX_QUEUE_SIZE_PER_HANDLER;"
Modified:
hbase/trunk/CHANGES.txt
hbase/trunk/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java
Modified: hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/trunk/CHANGES.txt?rev=1099695&r1=1099694&r2=1099695&view=diff
==============================================================================
--- hbase/trunk/CHANGES.txt (original)
+++ hbase/trunk/CHANGES.txt Thu May 5 06:07:56 2011
@@ -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
Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java?rev=1099695&r1=1099694&r2=1099695&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java Thu May 5 06:07:56 2011
@@ -89,7 +89,7 @@ public abstract class HBaseServer implem
/**
* 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 implem
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);