cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject cassandra git commit: Choose better poolingOptions for protocol v4 in cassandra-stress
Date Thu, 27 Aug 2015 20:02:55 GMT
Repository: cassandra
Updated Branches:
  refs/heads/cassandra-3.0 f00a3da83 -> 16b9f8bba


Choose better poolingOptions for protocol v4 in cassandra-stress

Patch by tjake; reviewed by Alan Boudreault for CASSANDRA-10182


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/16b9f8bb
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/16b9f8bb
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/16b9f8bb

Branch: refs/heads/cassandra-3.0
Commit: 16b9f8bba440a8c027fb0b3e801406dca1aaaa8d
Parents: f00a3da
Author: T Jake Luciani <jake@apache.org>
Authored: Tue Aug 25 15:02:04 2015 -0400
Committer: T Jake Luciani <jake@apache.org>
Committed: Thu Aug 27 16:00:18 2015 -0400

----------------------------------------------------------------------
 CHANGES.txt                                               |  1 +
 .../apache/cassandra/stress/util/JavaDriverClient.java    | 10 +++++++---
 2 files changed, 8 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/16b9f8bb/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index eef7974..457814f 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
 3.0.0-beta2
+ * Choose better poolingOptions for protocol v4 in cassandra-stress (CASSANDRA-10182)
  * Fix LWW bug affecting Materialized Views (CASSANDRA-10197)
  * Ensures frozen sets and maps are always sorted (CASSANDRA-10162)
  * Don't deadlock when flushing CFS backed custom indexes (CASSANDRA-10181)

http://git-wip-us.apache.org/repos/asf/cassandra/blob/16b9f8bb/tools/stress/src/org/apache/cassandra/stress/util/JavaDriverClient.java
----------------------------------------------------------------------
diff --git a/tools/stress/src/org/apache/cassandra/stress/util/JavaDriverClient.java b/tools/stress/src/org/apache/cassandra/stress/util/JavaDriverClient.java
index 8be1c96..0040003 100644
--- a/tools/stress/src/org/apache/cassandra/stress/util/JavaDriverClient.java
+++ b/tools/stress/src/org/apache/cassandra/stress/util/JavaDriverClient.java
@@ -89,13 +89,17 @@ public class JavaDriverClient
 
     public void connect(ProtocolOptions.Compression compression) throws Exception
     {
-        PoolingOptions poolingOpts = new PoolingOptions();
-        poolingOpts.setCoreConnectionsPerHost(HostDistance.LOCAL, 8);
+
+        PoolingOptions poolingOpts = new PoolingOptions()
+                                     .setConnectionsPerHost(HostDistance.LOCAL, 8, 8)
+                                     .setMaxRequestsPerConnection(HostDistance.LOCAL, 128)
+                                     .setNewConnectionThreshold(HostDistance.LOCAL, 100);
+
         Cluster.Builder clusterBuilder = Cluster.builder()
                                                 .addContactPoint(host)
                                                 .withPort(port)
                                                 .withPoolingOptions(poolingOpts)
-                                                .withProtocolVersion(ProtocolVersion.V2)
+                                                .withoutJMXReporting()
                                                 .withoutMetrics(); // The driver uses metrics
3 with conflict with our version
         if (whitelist != null)
             clusterBuilder.withLoadBalancingPolicy(whitelist);


Mime
View raw message