[CASSANDRA-7618] Upgrade Cassandra Java driver to 2.0.3 release

• Type: Improvement
• Status: Resolved
• Priority: Low
• Resolution: Fixed
• Fix Version/s: 2.0.10
• Assignee: Alex Liu
• Reporter: Alex Liu

Authors

Alex Liu

Reviewers

Sylvain Lebresne

• Created: 24/Jul/14 23:00
• Updated: 16/Apr/19 09:31
• Resolved: 05/Aug/14 08:23

Description

I got the following errors after upgrading to 2.0.3, need change our code accordingly.

14/07/24 15:37:21 DEBUG input.HiveCqlInputFormat: column mappings: "x","y","z"
14/07/24 15:37:21 DEBUG input.HiveCqlInputFormat: input query: SELECT "x","y","z" FROM "ks"."tab" WHERE token("x") > ? AND token("x") <= ? 
14/07/24 15:37:21 WARN cql3.CqlRecordReader: Failed to create authenticated client to localhost
Failed with exception java.io.IOException:java.io.IOException: java.lang.RuntimeException: java.lang.IllegalArgumentException: Min simultaneous requests per connection for REMOTE hosts must be less than max (25 > 0)
14/07/24 15:37:21 ERROR CliDriver: Failed with exception java.io.IOException:java.io.IOException: java.lang.RuntimeException: java.lang.IllegalArgumentException: Min simultaneous requests per connection for REMOTE hosts must be less than max (25 > 0)
java.io.IOException: java.io.IOException: java.lang.RuntimeException: java.lang.IllegalArgumentException: Min simultaneous requests per connection for REMOTE hosts must be less than max (25 > 0)
	at org.apache.hadoop.hive.ql.exec.FetchOperator.getNextRow(FetchOperator.java:551)
	at org.apache.hadoop.hive.ql.exec.FetchOperator.pushRow(FetchOperator.java:489)
	at org.apache.hadoop.hive.ql.exec.FetchTask.fetch(FetchTask.java:136)
	at org.apache.hadoop.hive.ql.Driver.getResults(Driver.java:1471)
	at org.apache.hadoop.hive.cli.CliDriver.processLocalCmd(CliDriver.java:271)
	at org.apache.hadoop.hive.cli.CliDriver.processCmd(CliDriver.java:216)
	at org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:413)
	at org.apache.hadoop.hive.cli.CliDriver.executeDriver(CliDriver.java:781)
	at org.apache.hadoop.hive.cli.CliDriver.run(CliDriver.java:675)
	at org.apache.hadoop.hive.cli.CliDriver.main(CliDriver.java:614)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.apache.hadoop.util.RunJar.main(RunJar.java:156)
Caused by: java.io.IOException: java.lang.RuntimeException: java.lang.IllegalArgumentException: Min simultaneous requests per connection for REMOTE hosts must be less than max (25 > 0)
	at org.apache.hadoop.hive.cassandra.cql3.input.HiveCqlInputFormat.getRecordReader(HiveCqlInputFormat.java:206)
	at org.apache.hadoop.hive.ql.exec.FetchOperator.getRecordReader(FetchOperator.java:433)
	at org.apache.hadoop.hive.ql.exec.FetchOperator.getNextRow(FetchOperator.java:515)
	... 14 more
Caused by: java.lang.RuntimeException: java.lang.IllegalArgumentException: Min simultaneous requests per connection for REMOTE hosts must be less than max (25 > 0)
	at org.apache.cassandra.hadoop.cql3.CqlRecordReader.initialize(CqlRecordReader.java:123)
	at org.apache.hadoop.hive.cassandra.cql3.input.CqlHiveRecordReader.initialize(CqlHiveRecordReader.java:95)
	at org.apache.hadoop.hive.cassandra.cql3.input.HiveCqlInputFormat.getRecordReader(HiveCqlInputFormat.java:201)
	... 16 more
Caused by: java.lang.IllegalArgumentException: Min simultaneous requests per connection for REMOTE hosts must be less than max (25 > 0)
	at com.datastax.driver.core.PoolingOptions.checkRequestsPerConnectionOrder(PoolingOptions.java:238)
	at com.datastax.driver.core.PoolingOptions.setMaxSimultaneousRequestsPerConnectionThreshold(PoolingOptions.java:147)
	at org.apache.cassandra.hadoop.cql3.CqlConfigHelper.getReadPoolingOptions(CqlConfigHelper.java:431)
	at org.apache.cassandra.hadoop.cql3.CqlConfigHelper.getInputCluster(CqlConfigHelper.java:298)
	at org.apache.cassandra.hadoop.cql3.CqlRecordReader.initialize(CqlRecordReader.java:109)
	... 18 more