com.datastax.driver.core.exceptions.DriverInternalError

There are no available Samebug tips for this exception. Do you have an idea how to solve this issue? A short tip would help users who saw this issue last week.

  • Here is the stacktrace : {code} com.datastax.driver.core.exceptions.DriverInternalError: Unexpected error while processing response from /node5:9042 at com.datastax.driver.core.exceptions.DriverInternalError.copy(DriverInternalError.java:42) at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:289) at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:205) at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52) (...) Caused by: com.datastax.driver.core.exceptions.DriverInternalError: Unexpected error while processing response from /node5:9042 at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:150) at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:249) at com.datastax.driver.core.RequestHandler.onSet(RequestHandler.java:281) at com.datastax.driver.core.Connection$Dispatcher.messageReceived(Connection.java:697) at com.datastax.shaded.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) at com.datastax.shaded.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) at com.datastax.shaded.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) at com.datastax.shaded.netty.channel.Channels.fireMessageReceived(Channels.java:296) at com.datastax.shaded.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream(OneToOneDecoder.java:70) at com.datastax.shaded.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) at com.datastax.shaded.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) at com.datastax.shaded.netty.channel.Channels.fireMessageReceived(Channels.java:296) at com.datastax.shaded.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:462) at com.datastax.shaded.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:443) at com.datastax.shaded.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303) at com.datastax.shaded.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) at com.datastax.shaded.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) at com.datastax.shaded.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559) at com.datastax.shaded.netty.channel.Channels.fireMessageReceived(Channels.java:268) at com.datastax.shaded.netty.channel.Channels.fireMessageReceived(Channels.java:255) at com.datastax.shaded.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88) at com.datastax.shaded.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108) at com.datastax.shaded.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318) at com.datastax.shaded.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89) at com.datastax.shaded.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178) at com.datastax.shaded.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) at com.datastax.shaded.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) ... 3 more Caused by: java.lang.NullPointerException at com.datastax.driver.core.ArrayBackedResultSet.checkWasApplied(ArrayBackedResultSet.java:414) at com.datastax.driver.core.ArrayBackedResultSet.<init>(ArrayBackedResultSet.java:51) at com.datastax.driver.core.ArrayBackedResultSet.<init>(ArrayBackedResultSet.java:36) at com.datastax.driver.core.ArrayBackedResultSet$SinglePage.<init>(ArrayBackedResultSet.java:159) at com.datastax.driver.core.ArrayBackedResultSet$SinglePage.<init>(ArrayBackedResultSet.java:150) at com.datastax.driver.core.ArrayBackedResultSet.fromMessage(ArrayBackedResultSet.java:75) at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:135) ... 29 more {code} It occurred with a prepared statement {{​SELECT valCol FROM ks.table WHERE keyCol = ?;}} where _keyCol_ is a _BIGINT_ and _valCol_ a _UUID_ (index table).
    via by Fabrice Larcher,
  • We cache our prepared queries in our application prior to creating and executing bound statements. That means that every query used by our application (~25 queries total) is prepared exactly once. When using java driver versions 1.0.2, 1.0.3, and 1.04, this worked fine. However, upon upgrading to 2.0.0-rc1 our unit tests (which start up an embedded Cassandra instance and run various queries against it) began failing. The exception we're getting is: com.datastax.driver.core.exceptions.DriverInternalError: Tried to execute unknown prepared query 0x62877b61e4ebbaefa7dc01b4a0fdb4c6 at com.datastax.driver.core.exceptions.DriverInternalError.copy(DriverInternalError.java:42) at com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException(ResultSetFuture.java:271) at com.datastax.driver.core.ResultSetFuture.getUninterruptibly(ResultSetFuture.java:187) at com.datastax.driver.core.Session.execute(Session.java:126) ... 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:601) at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47) at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44) at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26) at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271) at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70) at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50) at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238) at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63) at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236) at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53) at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229) at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26) at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27) at org.junit.runners.ParentRunner.run(ParentRunner.java:309) at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50) at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38) at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:467) at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:683) at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:390) at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:197) Caused by: com.datastax.driver.core.exceptions.DriverInternalError: Tried to execute unknown prepared query 0x62877b61e4ebbaefa7dc01b4a0fdb4c6 at com.datastax.driver.core.RequestHandler.onSet(RequestHandler.java:324) at com.datastax.driver.core.Connection$Dispatcher.messageReceived(Connection.java:510) at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296) at org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream(OneToOneDecoder.java:70) at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296) at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:462) at org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:443) at org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303) at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559) at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268) at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255) at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88) at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:109) at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312) at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:90) at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178) at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) at java.lang.Thread.run(Thread.java:722) This exception seems to be being created at com.datastax.driver.core.RequestHandler:322 after a comment that says "// This shouldn't happen". The underlying problem seems to be that the preparedQueries map is using weak keys. As a result, the application level cached queries are more durable than the ones in the driver, causing queries to start failing once the weak reference to the query key is lost.
    via by Phil Persad,
  • Problem: When I call `CassandraRepository#save(...)` with too many items I get an exception: ERROR [2014-08-29 10:13:54,906] my.project.Klazz: Could not store stuff ! com.datastax.driver.core.exceptions.DriverInternalError: An unexpected error occurred server side on /10.11.1.32:9042: java.lang.IndexOutOfBoundsException: Index: 5482, Size: 5482 ! at com.datastax.driver.core.exceptions.DriverInternalError.copy(DriverInternalError.java:42) ! at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:256) ! at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:172) ! at com.datastax.driver.core.SessionManager.execute(SessionManager.java:92) ! at org.springframework.cassandra.core.CqlTemplate$12.doInSession(CqlTemplate.java:518) ! at org.springframework.cassandra.core.CqlTemplate$12.doInSession(CqlTemplate.java:509) ! at org.springframework.cassandra.core.CqlTemplate.doExecute(CqlTemplate.java:486) ! at org.springframework.cassandra.core.CqlTemplate.doExecute(CqlTemplate.java:509) ! at org.springframework.cassandra.core.CqlTemplate.execute(CqlTemplate.java:1197) ! at org.springframework.data.cassandra.core.CassandraTemplate.batchInsert(CassandraTemplate.java:547) ! at org.springframework.data.cassandra.core.CassandraTemplate.insert(CassandraTemplate.java:201) ! at org.springframework.data.cassandra.core.CassandraTemplate.insert(CassandraTemplate.java:196) ! at org.springframework.data.cassandra.repository.support.SimpleCassandraRepository.save(SimpleCassandraRepository.java:64) ! at org.springframework.data.cassandra.repository.support.SimpleCassandraRepository.save(SimpleCassandraRepository.java:36) ! at sun.reflect.GeneratedMethodAccessor414.invoke(Unknown Source) ! at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ! at java.lang.reflect.Method.invoke(Method.java:606) ! at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.executeMethodOn(RepositoryFactorySupport.java:405) ! at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.doInvoke(RepositoryFactorySupport.java:390) ! at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.invoke(RepositoryFactorySupport.java:344) ! at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172) ! at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:204) ! at com.sun.proxy.$Proxy157.save(Unknown Source) ! at my.project.SomeOtherKlazz.process(SomeOtherKlazz.java:319) ! at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) ! at java.util.concurrent.FutureTask.run(FutureTask.java:262) ! at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) ! at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) ! at java.lang.Thread.run(Thread.java:745) Caused by: ! com.datastax.driver.core.exceptions.DriverInternalError: An unexpected error occurred server side on /10.11.1.32:9042: java.lang.IndexOutOfBoundsException: Index: 5482, Size: 5482 ! at com.datastax.driver.core.Responses$Error.asException(Responses.java:86) ! at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:108) ! at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:235) ! at com.datastax.driver.core.RequestHandler.onSet(RequestHandler.java:367) ! at com.datastax.driver.core.Connection$Dispatcher.messageReceived(Connection.java:571) ! at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) ! at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) ! at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) ! at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296) ! at org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream(OneToOneDecoder.java:70) ! at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) ! at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) ! at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296) ! at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:462) ! at org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:443) ! at org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303) ! at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) ! at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) ! at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559) ! at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268) ! at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255) ! at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88) ! at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:109) ! at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312) ! at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:90) ! at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178) ! at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) ! at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) !... 3 common frames omitted In Cassandra I am getting: WARN [Native-Transport-Requests:683742] 2014-08-29 10:22:14,838 BatchStatement.java (line 223) Batch of prepared statements for [mykeyspace.mytable] is of size 229558, exceeding specified threshold of 65536 by 164022. I would expect spring-data-cassandra to take care of the smaller batching for me. Workaround: Implement a custom repository method that saves the items in small batches.
    via by Jens Rantil,
  • This test failed on the new 2.0 branch when, I believe, failList attempts to use L_Q on a cluster with a SS keyspace, instead of an NTS keyspace. {CODE} Starting com.datastax.driver.core.ConsistencyTest.testRFOneDowngradingCL [1/1]... 0 [main] INFO com.datastax.driver.core.Cluster - New Cassandra host /127.0.1.2 added 8 [main] INFO com.datastax.driver.core.Cluster - New Cassandra host /127.0.1.3 added 2551 [main] INFO com.datastax.driver.core.CCMBridge - Force stopping: 127.0.1.2 3778 [main] INFO com.datastax.driver.core.TestUtils - Waiting for stopped node: 127.0.1.2 126921 [main] WARN com.datastax.driver.core.Cluster - Re-preparing already prepared query SELECT * FROM test WHERE k = ?. Please note that preparing the same query more than once is generally an anti-pattern and will likely affect performance. Consider preparing the statement only once. 156347 [main] INFO com.datastax.driver.core.CCMBridge - Error during tests, kept C* logs in /var/folders/mh/h_jxf_b943x5tl9kv_hf2j3h0000gn/T/1388701344772-0 com.datastax.driver.core.exceptions.DriverInternalError: An unexpected error occured server side on /127.0.1.1: java.lang.ClassCastException: org.apache.cassandra.locator.SimpleStrategy cannot be cast to org.apache.cassandra.locator.NetworkTopologyStrategy at com.datastax.driver.core.exceptions.DriverInternalError.copy(DriverInternalError.java:42) at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:256) at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:172) at com.datastax.driver.core.SessionManager.execute(SessionManager.java:74) at com.datastax.driver.core.AbstractPoliciesTest.query(AbstractPoliciesTest.java:164) at com.datastax.driver.core.AbstractPoliciesTest.query(AbstractPoliciesTest.java:152) at com.datastax.driver.core.ConsistencyTest.testRFOneDowngradingCL(ConsistencyTest.java:405) {CODE}
    via by Joaquin Casares,
  • If I submit a {{null}} value to variable bound to a column which is a collection inside a UDT, then I get a NPE. No problem without prepared statements. No problem with columns of any native type inside a UDT. No problem if the value is not {{null}}. But also fails if no value is submitted for the corresponding column of the UDT (seems to be equivalent). Here is a code sample that reproduces the problem (at least on my computer) : {code} session.execute("CREATE KEYSPACE IF NOT EXISTS ks WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 1 }"); session.execute("CREATE TYPE IF NOT EXISTS ks.my_type ( bla ascii, val int, l list<int>);"); session.execute("CREATE TABLE IF NOT EXISTS ks.udt_table (key int, udt my_type, PRIMARY KEY (key));"); session.execute("INSERT INTO ks.udt_table (key, udt) VALUES (1, { bla : 'toto', val : 42 });"); // OK PreparedStatement prepared = session.prepare(new SimpleStatement("INSERT INTO ks.udt_table (key, udt) VALUES (2, { bla : ?, val : ?, l: ? });")); BoundStatement bound = prepared.bind( "toto", 42, Lists.newArrayList(12)); session.execute(bound); // OK prepared = session.prepare(new SimpleStatement("INSERT INTO ks.udt_table (key, udt) VALUES (3, { bla : ?, val : ?, l: ? });")); bound = prepared.bind( "toto", null, Lists.newArrayList(12)); session.execute(bound); // OK prepared = session.prepare(new SimpleStatement("INSERT INTO ks.udt_table (key, udt) VALUES (4, { bla : ?, val : ?, l: ? });")); bound = prepared.bind( "toto", 42, null); session.execute(bound); // NOK prepared = session.prepare(new SimpleStatement("INSERT INTO ks.udt_table (key, udt) VALUES (5, { bla : ?, val : ? });")); bound = prepared.bind( "toto", 42); session.execute(bound); // NOK {code} Here is the stacktrace in application's log : {code} com.datastax.driver.core.exceptions.DriverInternalError: An unexpected error occurred server side on /127.0.0.1:9042: java.lang.NullPointerException at com.datastax.driver.core.exceptions.DriverInternalError.copy(DriverInternalError.java:42) at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:258) at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:174) at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52) (...) Caused by: com.datastax.driver.core.exceptions.DriverInternalError: An unexpected error occurred server side on /127.0.0.1:9042: java.lang.NullPointerException at com.datastax.driver.core.Responses$Error.asException(Responses.java:86) at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:110) at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:235) at com.datastax.driver.core.RequestHandler.onSet(RequestHandler.java:367) at com.datastax.driver.core.Connection$Dispatcher.messageReceived(Connection.java:584) at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296) at org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream(OneToOneDecoder.java:70) at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296) at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:462) at org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:443) at org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303) at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559) at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268) at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255) at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88) at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108) at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318) at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89) at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178) at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:745) {code} Here is the stacktrace in system.log file : {code} ERROR [SharedPool-Worker-2] 2014-07-31 11:35:57,241 ErrorMessage.java:218 - Unexpected exception during request java.lang.NullPointerException: null at org.apache.cassandra.serializers.ListSerializer.deserializeForNativeProtocol(ListSerializer.java:82) ~[apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.serializers.ListSerializer.deserializeForNativeProtocol(ListSerializer.java:27) ~[apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.serializers.CollectionSerializer.reserializeToV3(CollectionSerializer.java:53) ~[apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.cql3.UserTypes$DelayedValue.bindInternal(UserTypes.java:175) ~[apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.cql3.UserTypes$DelayedValue.bindAndGet(UserTypes.java:188) ~[apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.cql3.Constants$Setter.execute(Constants.java:314) ~[apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.cql3.statements.UpdateStatement.addUpdateForKey(UpdateStatement.java:97) ~[apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.cql3.statements.ModificationStatement.getMutations(ModificationStatement.java:672) ~[apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.cql3.statements.ModificationStatement.executeWithoutCondition(ModificationStatement.java:501) ~[apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.cql3.statements.ModificationStatement.execute(ModificationStatement.java:487) ~[apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:187) ~[apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.cql3.QueryProcessor.processPrepared(QueryProcessor.java:413) ~[apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.transport.messages.ExecuteMessage.execute(ExecuteMessage.java:133) ~[apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.transport.Message$Dispatcher.channelRead0(Message.java:421) [apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.transport.Message$Dispatcher.channelRead0(Message.java:318) [apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:103) [netty-all-4.0.20.Final.jar:4.0.20.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:332) [netty-all-4.0.20.Final.jar:4.0.20.Final] at io.netty.channel.AbstractChannelHandlerContext.access$700(AbstractChannelHandlerContext.java:31) [netty-all-4.0.20.Final.jar:4.0.20.Final] at io.netty.channel.AbstractChannelHandlerContext$8.run(AbstractChannelHandlerContext.java:323) [netty-all-4.0.20.Final.jar:4.0.20.Final] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) [na:1.7.0_55] at org.apache.cassandra.concurrent.AbstractTracingAwareExecutorService$FutureTask.run(AbstractTracingAwareExecutorService.java:162) [apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:103) [apache-cassandra-2.1.0-rc4.jar:2.1.0-rc4] at java.lang.Thread.run(Thread.java:744) [na:1.7.0_55] {code} Is related to https://groups.google.com/a/lists.datastax.com/forum/#!topic/java-driver-user/oKTbrRy5GeU
    via by Fabrice Larcher,
  • This was reported by one of our customers; it happens under heavy load, during a performance test. I've not been able to reproduce it yet. A statement is prepared for {{SELECT v FROM foobar WHERE k = ?}} (k and v are blobs). Then bound statements for various partition keys are executed. One of them fails with: {code} ERROR [main]: com.datastax.driver.core.exceptions.DriverInternalError com.datastax.driver.core.exceptions.DriverInternalError: Unexpected error while processing response from /xxxxxxx:9042 at com.datastax.driver.core.exceptions.DriverInternalError.copy(DriverInternalError.java:42) at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:258) at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:174) at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52) [...] Caused by: com.datastax.driver.core.exceptions.DriverInternalError: Unexpected error while processing response from /xxxxxxxxx:9042 at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:120) at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:237) at com.datastax.driver.core.RequestHandler.onSet(RequestHandler.java:261) at com.datastax.driver.core.Connection$Dispatcher.messageReceived(Connection.java:645) [...] Caused by: java.lang.NullPointerException at com.datastax.driver.core.ArrayBackedResultSet.checkWasApplied(ArrayBackedResultSet.java:414) at com.datastax.driver.core.ArrayBackedResultSet.<init>(ArrayBackedResultSet.java:51) at com.datastax.driver.core.ArrayBackedResultSet.<init>(ArrayBackedResultSet.java:36) at com.datastax.driver.core.ArrayBackedResultSet$SinglePage.<init>(ArrayBackedResultSet.java:165) at com.datastax.driver.core.ArrayBackedResultSet$SinglePage.<init>(ArrayBackedResultSet.java:156) at com.datastax.driver.core.ArrayBackedResultSet.fromMessage(ArrayBackedResultSet.java:81) at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:105) ... 29 more {code} Upon further investigation (the customer applied a patch to generate more logs), it turns out that the PreparedId stored client-side has no metadata associated with it; therefore the EXECUTE request is sent with SKIP_METADATA = false; but the ROWS response returned by Cassandra has no metadata, hence the error. I've observed the messages after deserialization, so that could be a bug in the serialization layer.
    via by Olivier Michallat,
    • com.datastax.driver.core.exceptions.DriverInternalError: An unexpected error occured server side on /127.0.1.1: java.lang.IllegalArgumentException: Illegal Capacity: -1 at com.datastax.driver.core.exceptions.DriverInternalError.copy(DriverInternalError.java:42) at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:256) at com.datastax.driver.core.ArrayBackedResultSet.fetchMoreResultsBlocking(ArrayBackedResultSet.java:197) at com.datastax.driver.core.ArrayBackedResultSet.isExhausted(ArrayBackedResultSet.java:135) at com.datastax.driver.core.FetchingTest.simplePagingTest(FetchingTest.java:57)
    No Bugmate found.