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] [Created] (CASSANDRA-7618) Upgrade Cassandra Java driver to 2.0.3 release
Date Thu, 24 Jul 2014 23:01:39 GMT
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)

Mime
View raw message