cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Alex Liu (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (CASSANDRA-7618) Upgrade Cassandra Java driver to 2.0.3 release
Date Thu, 24 Jul 2014 23:03:38 GMT

     [ 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)

Mime
View raw message