cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tyler Hobbs (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (CASSANDRA-7470) java.lang.AssertionError are causing cql responses to always go to streamId = 0 instead of the request sending streamId
Date Thu, 10 Jul 2014 16:58:04 GMT

     [ https://issues.apache.org/jira/browse/CASSANDRA-7470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Tyler Hobbs updated CASSANDRA-7470:
-----------------------------------

    Attachment: 7470.txt

The actual fix that's needed is to catch Throwables in Message.Dispatcher.messageReceived()
(instead of just catching Exception) so that we cover QueryMessage and BatchMessage as well
as ExecuteMessage.

The attached 7470.txt applies to 1.2.

> java.lang.AssertionError are causing cql responses to always go to streamId = 0 instead
of the request sending streamId
> -----------------------------------------------------------------------------------------------------------------------
>
>                 Key: CASSANDRA-7470
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-7470
>             Project: Cassandra
>          Issue Type: Bug
>          Components: API
>         Environment: CQL native interface
>            Reporter: Dominic Letz
>            Priority: Trivial
>              Labels: cql
>             Fix For: 1.2.19, 2.0.10, 2.1.0
>
>         Attachments: 7470.txt, letz.patch
>
>
> 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)



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Mime
View raw message