cassandra - setfetchsize in datastax java : when fetchSize == rowcount then it fails with exception DriverInternalError -

cassandra - setfetchsize in datastax java : when fetchSize == rowcount then it fails with exception DriverInternalError -

the versions used : datastax java driver 2.0.1 & 2.0.2

cassandra version : [cqlsh 4.1.0 | cassandra 2.0.4 | cql spec 3.1.1 | thrift protocol 19.39.0]

code part:

statement stmt = new simplestatement("select id accounts;"); stmt.setfetchsize(5); session.execute(stmt); (row r:result.all()){ system.out.println(r.tostring()); }

or

(row r:result){ system.out.println(r.tostring()); }

exception happens @

for (row r:result)

exception in thread "main" com.datastax.driver.core.exceptions.driverinternalerror: unexpected error occurred server side on /122.248.212.139:9042: java.lang.illegalargumentexception: illegal capacity: -1 @ com.datastax.driver.core.exceptions.driverinternalerror.copy(driverinternalerror.java:42) @ com.datastax.driver.core.defaultresultsetfuture.extractcausefromexecutionexception(defaultresultsetfuture.java:256) @ com.datastax.driver.core.arraybackedresultset$multipage.preparenextrow(arraybackedresultset.java:259) @ com.datastax.driver.core.arraybackedresultset$multipage.isexhausted(arraybackedresultset.java:222) @ com.datastax.driver.core.arraybackedresultset$1.hasnext(arraybackedresultset.java:115) @ com.datastax.driver.core.arraybackedresultset.all(arraybackedresultset.java:104) @ com.minjar.simplifyit.cost.data.cassandra.datastaxcassandrahandler.main(datastaxcassandrahandler.java:407) caused by: com.datastax.driver.core.exceptions.driverinternalerror: unexpected error occurred server side on /122.248.212.139:9042: java.lang.illegalargumentexception: illegal capacity: -1 @ com.datastax.driver.core.responses$error.asexception(responses.java:86) @ com.datastax.driver.core.arraybackedresultset$multipage$1.onset(arraybackedresultset.java:329) @ com.datastax.driver.core.requesthandler.setfinalresult(requesthandler.java:235) @ com.datastax.driver.core.requesthandler.onset(requesthandler.java:367) @ com.datastax.driver.core.connection$dispatcher.messagereceived(connection.java:571) @ org.jboss.netty.channel.simplechannelupstreamhandler.handleupstream(simplechannelupstreamhandler.java:70) @ org.jboss.netty.channel.defaultchannelpipeline.sendupstream(defaultchannelpipeline.java:564) @ org.jboss.netty.channel.defaultchannelpipeline$defaultchannelhandlercontext.sendupstream(defaultchannelpipeline.java:791) @ org.jboss.netty.channel.channels.firemessagereceived(channels.java:296) @ org.jboss.netty.handler.codec.oneone.onetoonedecoder.handleupstream(onetoonedecoder.java:70) @ org.jboss.netty.channel.defaultchannelpipeline.sendupstream(defaultchannelpipeline.java:564) @ org.jboss.netty.channel.defaultchannelpipeline$defaultchannelhandlercontext.sendupstream(defaultchannelpipeline.java:791) @ org.jboss.netty.channel.channels.firemessagereceived(channels.java:296) @ org.jboss.netty.handler.codec.frame.framedecoder.unfoldandfiremessagereceived(framedecoder.java:462) @ org.jboss.netty.handler.codec.frame.framedecoder.calldecode(framedecoder.java:443) @ org.jboss.netty.handler.codec.frame.framedecoder.messagereceived(framedecoder.java:303) @ org.jboss.netty.channel.simplechannelupstreamhandler.handleupstream(simplechannelupstreamhandler.java:70) @ org.jboss.netty.channel.defaultchannelpipeline.sendupstream(defaultchannelpipeline.java:564) @ org.jboss.netty.channel.defaultchannelpipeline.sendupstream(defaultchannelpipeline.java:559) @ org.jboss.netty.channel.channels.firemessagereceived(channels.java:268) @ org.jboss.netty.channel.channels.firemessagereceived(channels.java:255) @ org.jboss.netty.channel.socket.nio.nioworker.read(nioworker.java:88) @ org.jboss.netty.channel.socket.nio.abstractnioworker.process(abstractnioworker.java:108) @ org.jboss.netty.channel.socket.nio.abstractnioselector.run(abstractnioselector.java:318) @ org.jboss.netty.channel.socket.nio.abstractnioworker.run(abstractnioworker.java:89) @ org.jboss.netty.channel.socket.nio.nioworker.run(nioworker.java:178) @ org.jboss.netty.util.threadrenamingrunnable.run(threadrenamingrunnable.java:108) @ org.jboss.netty.util.internal.deadlockproofworker$1.run(deadlockproofworker.java:42) @ java.util.concurrent.threadpoolexecutor.runworker(threadpoolexecutor.java:1145) @ java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor.java:615) @ java.lang.thread.run(thread.java:744)

i can reproduce problem cassandra 2.0.4, not 2.0.5. guess you're running cassandra-6555.

i suggest upgrading cluster latest stable version, 2.0.8.

java cassandra cql datastax