[
https://issues.apache.org/jira/browse/CASSANDRA-7618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex Liu updated CASSANDRA-7618:
--------------------------------
Attachment: 7618.txt
> Upgrade Cassandra Java driver to 2.0.3 release
> ----------------------------------------------
>
> Key: CASSANDRA-7618
> URL: https://issues.apache.org/jira/browse/CASSANDRA-7618
> Project: Cassandra
> Issue Type: New Feature
> Components: Hadoop
> Reporter: Alex Liu
> Assignee: Alex Liu
> Priority: Minor
> Fix For: 2.0.10
>
> Attachments: 7618.txt
>
>
> I got the following errors after upgrading to 2.0.3, need change our code
> accordingly.
> {code}
> 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
> {code}
--
This message was sent by Atlassian JIRA
(v6.2#6252)
