cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Yuki Morishita (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (CASSANDRA-10557) Streaming can throw exception when trying to retry
Date Mon, 26 Oct 2015 18:02:28 GMT

    [ https://issues.apache.org/jira/browse/CASSANDRA-10557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974680#comment-14974680
] 

Yuki Morishita commented on CASSANDRA-10557:
--------------------------------------------

This may relate to CASSANDRA-10448, but I'm not sure since the log we got was not complete.

bq. there was no retry and that exception was not thrown during SSTableWriter.abort() call.
Could you please clarify?

Streaming can try to read next message from the middle of failed stream, thus we need to drain
unread data.
And I think that's the source of this "Unknown type 0" error.
{{SSTableWriter.abort()}} can throw RuntimeException which is not handled by anything and
if that happens it will leave incomplete stream.



> Streaming can throw exception when trying to retry
> --------------------------------------------------
>
>                 Key: CASSANDRA-10557
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-10557
>             Project: Cassandra
>          Issue Type: Bug
>            Reporter: Yuki Morishita
>            Assignee: Yuki Morishita
>            Priority: Minor
>             Fix For: 2.1.x, 2.2.x, 3.0.0
>
>
> Streaming can throw below exception when trying to retry.
> This seems to be happening when underlining cause is not catched properly.
> {code}
> ERROR 18:45:56 [Stream #9f95fa90-7691-11e5-931f-5b735851f84a] Streaming error occurred
> java.lang.IllegalArgumentException: Unknown type 0
>         at org.apache.cassandra.streaming.messages.StreamMessage$Type.get(StreamMessage.java:97)
~[main/:na]
>         at org.apache.cassandra.streaming.messages.StreamMessage.deserialize(StreamMessage.java:58)
~[main/:na]
>         at org.apache.cassandra.streaming.ConnectionHandler$IncomingMessageHandler.run(ConnectionHandler.java:261)
~[main/:na]
>         at java.lang.Thread.run(Thread.java:745) [na:1.8.0_45]
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message