diff --git a/CHANGES.txt b/CHANGES.txt index a179fb6fc3..10f7b57eab 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -34,6 +34,7 @@ Merged from 2.0: 2.1.0-final * cqlsh DESC CLUSTER fails retrieving ring information (CASSANDRA-7687) Merged from 2.0: + * Update java driver (for hadoop) (CASSANDRA-7618) * Support connecting to ipv6 jmx with nodetool (CASSANDRA-7669) diff --git a/build.xml b/build.xml index 438ffb290e..d887bb6747 100644 --- a/build.xml +++ b/build.xml @@ -390,7 +390,7 @@ - + diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java index b375ce258a..741f599f80 100644 --- a/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java +++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java @@ -422,15 +422,15 @@ public class CqlConfigHelper poolingOptions.setCoreConnectionsPerHost(HostDistance.LOCAL, coreConnections.get()); if (maxConnections.isPresent()) poolingOptions.setMaxConnectionsPerHost(HostDistance.LOCAL, maxConnections.get()); - if (maxSimultaneousRequests.isPresent()) - poolingOptions.setMaxSimultaneousRequestsPerConnectionThreshold(HostDistance.LOCAL, maxSimultaneousRequests.get()); if (minSimultaneousRequests.isPresent()) poolingOptions.setMinSimultaneousRequestsPerConnectionThreshold(HostDistance.LOCAL, minSimultaneousRequests.get()); + if (maxSimultaneousRequests.isPresent()) + poolingOptions.setMaxSimultaneousRequestsPerConnectionThreshold(HostDistance.LOCAL, maxSimultaneousRequests.get()); poolingOptions.setCoreConnectionsPerHost(HostDistance.REMOTE, 0) .setMaxConnectionsPerHost(HostDistance.REMOTE, 0) - .setMaxSimultaneousRequestsPerConnectionThreshold(HostDistance.REMOTE, 0) - .setMinSimultaneousRequestsPerConnectionThreshold(HostDistance.REMOTE, 0); + .setMinSimultaneousRequestsPerConnectionThreshold(HostDistance.REMOTE, 0) + .setMaxSimultaneousRequestsPerConnectionThreshold(HostDistance.REMOTE, 0); return poolingOptions; }