[ https://issues.apache.org/jira/browse/CASSANDRA-7618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sylvain Lebresne updated CASSANDRA-7618: ---------------------------------------- Reviewer: Sylvain Lebresne Issue Type: Improvement (was: New Feature) > 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: Improvement > 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)