[CASSANDRA-7470] java.lang.AssertionError are causing cql responses to always go to streamId = 0 instead of the request sending streamId

• Type: Bug
• Status: Resolved
• Priority: Low
• Resolution: Fixed
• Fix Version/s: 1.2.19, 2.0.10, 2.1 rc4
• Component/s: Legacy/CQL
• Labels: cql

Environment

CQL native interface

• Severity: Low
• Assignee: Tom Hobbs
• Reporter: Dominic Letz

Authors

Tom Hobbs

Reviewers

Aleksey Yeschenko

• Created: 30/Jun/14 11:33
• Updated: 16/Apr/19 09:31
• Resolved: 10/Jul/14 21:27

Description

When triggering an unexpected assertion like the one below then then the ExecuteMessage.java is catching that and generates a response with a streamId = 0.
When sending multiple queries at the same time on different streams this makes it impossible to know which of those queries failed.

ERROR [Native-Transport-Requests:455] 2014-06-27 02:20:38,484 ErrorMessage.java (line 222) Unexpected exception during request
java.lang.AssertionError: Added column does not sort as the last column
at org.apache.cassandra.db.ArrayBackedSortedColumns.addColumn(ArrayBackedSortedColumns.java:115)
at org.apache.cassandra.db.ColumnFamily.addColumn(ColumnFamily.java:116)
at org.apache.cassandra.service.pager.AbstractQueryPager.discardHead(AbstractQueryPager.java:319)
at org.apache.cassandra.service.pager.AbstractQueryPager.discardLast(AbstractQueryPager.java:301)
at org.apache.cassandra.service.pager.AbstractQueryPager.discardFirst(AbstractQueryPager.java:219)
at org.apache.cassandra.service.pager.AbstractQueryPager.discardFirst(AbstractQueryPager.java:202)
at org.apache.cassandra.service.pager.AbstractQueryPager.fetchPage(AbstractQueryPager.java:124)
at org.apache.cassandra.service.pager.SliceQueryPager.fetchPage(SliceQueryPager.java:35)
at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:232)
at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:62)
at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:158)
at org.apache.cassandra.cql3.QueryProcessor.processPrepared(QueryProcessor.java:309)
at org.apache.cassandra.transport.messages.ExecuteMessage.execute(ExecuteMessage.java:132)
at org.apache.cassandra.transport.Message$Dispatcher.messageReceived(Message.java:304)
at org.jboss.netty.handler.execution.ChannelUpstreamEventRunnable.doRun(ChannelUpstreamEventRunnable.java:43)
at org.jboss.netty.handler.execution.ChannelEventRunnable.run(ChannelEventRunnable.java:67)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)