You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by "Alex Liu (JIRA)" <ji...@apache.org> on 2014/07/25 01:01:39 UTC
[jira] [Created] (CASSANDRA-7618) Upgrade Cassandra Java driver to
2.0.3 release
Alex Liu created CASSANDRA-7618:
-----------------------------------
Summary: 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
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)