hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From apurt...@apache.org
Subject svn commit: r1100300 - in /hbase/branches/0.90: CHANGES.txt src/main/java/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.java src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java src/test/resources/hbase-site.xml
Date Fri, 06 May 2011 17:43:06 GMT
Author: apurtell
Date: Fri May  6 17:43:06 2011
New Revision: 1100300

URL: http://svn.apache.org/viewvc?rev=1100300&view=rev
Log:
HBASE-3861 MiniZooKeeperCluster should refer to maxClientCnxns

Modified:
    hbase/branches/0.90/CHANGES.txt
    hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.java
    hbase/branches/0.90/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java
    hbase/branches/0.90/src/test/resources/hbase-site.xml

Modified: hbase/branches/0.90/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/CHANGES.txt?rev=1100300&r1=1100299&r2=1100300&view=diff
==============================================================================
--- hbase/branches/0.90/CHANGES.txt (original)
+++ hbase/branches/0.90/CHANGES.txt Fri May  6 17:43:06 2011
@@ -41,6 +41,8 @@ Release 0.90.3 - Unreleased
    HBASE-3821  "NOT flushing memstore for region" keep on printing for half
                an hour (zhoushuaifeng)
    HBASE-3848  request is always zero in WebUI for region server (gaojinchao)
+   HBASE-3861  MiniZooKeeperCluster should refer to maxClientCnxns (Eugene
+               Koontz via Andrew Purtell)
 
   IMPROVEMENT
    HBASE-3717  deprecate HTable isTableEnabled() methods in favor of HBaseAdmin

Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.java?rev=1100300&r1=1100299&r2=1100300&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.java
(original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.java
Fri May  6 17:43:06 2011
@@ -31,7 +31,9 @@ import java.net.Socket;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileUtil;
+import org.apache.hadoop.hbase.HBaseConfiguration;
 import org.apache.zookeeper.server.NIOServerCnxn;
 import org.apache.zookeeper.server.ZooKeeperServer;
 import org.apache.zookeeper.server.persistence.FileTxnLog;
@@ -53,9 +55,17 @@ public class MiniZooKeeperCluster {
   private NIOServerCnxn.Factory standaloneServerFactory;
   private int tickTime = 0;
 
+  private Configuration configuration;
+
   /** Create mini ZooKeeper cluster. */
   public MiniZooKeeperCluster() {
+    this(HBaseConfiguration.create());
+  }
+
+  /** Create mini ZooKeeper cluster with configuration (usually from test environment) */
+  public MiniZooKeeperCluster(Configuration configuration) {
     this.started = false;
+    this.configuration = configuration;
   }
 
   public void setClientPort(int clientPort) {
@@ -105,8 +115,9 @@ public class MiniZooKeeperCluster {
     ZooKeeperServer server = new ZooKeeperServer(dir, dir, tickTimeToUse);
     while (true) {
       try {
+        int numberOfConnections = this.configuration.getInt("hbase.zookeeper.property.maxClientCnxns",5000);
         standaloneServerFactory =
-          new NIOServerCnxn.Factory(new InetSocketAddress(clientPort));
+	  new NIOServerCnxn.Factory(new InetSocketAddress(clientPort), numberOfConnections);
       } catch (BindException e) {
         LOG.info("Failed binding ZK Server to client port: " + clientPort);
         //this port is already in use. try to use another

Modified: hbase/branches/0.90/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java?rev=1100300&r1=1100299&r2=1100300&view=diff
==============================================================================
--- hbase/branches/0.90/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java (original)
+++ hbase/branches/0.90/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java Fri
May  6 17:43:06 2011
@@ -260,7 +260,7 @@ public class HBaseTestingUtility {
     if (this.zkCluster != null) {
       throw new IOException("Cluster already running at " + dir);
     }
-    this.zkCluster = new MiniZooKeeperCluster();
+    this.zkCluster = new MiniZooKeeperCluster(this.getConfiguration());
     int clientPort = this.zkCluster.startup(dir);
     this.conf.set("hbase.zookeeper.property.clientPort",
       Integer.toString(clientPort));

Modified: hbase/branches/0.90/src/test/resources/hbase-site.xml
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/test/resources/hbase-site.xml?rev=1100300&r1=1100299&r2=1100300&view=diff
==============================================================================
--- hbase/branches/0.90/src/test/resources/hbase-site.xml (original)
+++ hbase/branches/0.90/src/test/resources/hbase-site.xml Fri May  6 17:43:06 2011
@@ -133,4 +133,14 @@
     The port at which the clients will connect.
     </description>
   </property>
+  <property>
+    <name>hbase.zookeeper.property.maxClientCnxns</name>
+    <value>5000</value>
+    <description>Property from ZooKeeper's config zoo.cfg.
+    Limit on number of concurrent connections (at the socket level) that a
+    single client, identified by IP address, may make to a single member of
+    the ZooKeeper ensemble. Set high to avoid zk connection issues running
+    standalone and pseudo-distributed.
+    </description>
+  </property>
 </configuration>



Mime
View raw message