You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by "Joel Knighton (JIRA)" <ji...@apache.org> on 2015/11/19 19:10:11 UTC
[jira] [Commented] (CASSANDRA-10737)
TestTopology.crash_during_decommission_test dtest sometimes fails due to
interrupted streaming
[ https://issues.apache.org/jira/browse/CASSANDRA-10737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15014054#comment-15014054 ]
Joel Knighton commented on CASSANDRA-10737:
-------------------------------------------
This test was introduced to cover the issue in 10231.
> TestTopology.crash_during_decommission_test dtest sometimes fails due to interrupted streaming
> -----------------------------------------------------------------------------------------------
>
> Key: CASSANDRA-10737
> URL: https://issues.apache.org/jira/browse/CASSANDRA-10737
> Project: Cassandra
> Issue Type: Bug
> Components: Testing
> Reporter: Joel Knighton
> Priority: Minor
>
> Example [here|http://cassci.datastax.com/job/cassandra-3.0_dtest/307/testReport/topology_test/TestTopology/crash_during_decommission_test/].
> The test fails due to an unexpected error in the log as follows:
> {code}
> Unexpected error in node1 node log: ['ERROR [STREAM-IN-/127.0.0.2] 2015-10-29 10:33:42,030 StreamSession.java:520 - [Stream #862cc220-7e28-11e5-b94f-5f64a052c605] Streaming error occurred java.io.IOException: Connection reset by peer \tat sun.nio.ch.FileDispatcherImpl.read0(Native Method) ~[na:1.8.0_45] \tat sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) ~[na:1.8.0_45] \tat sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) ~[na:1.8.0_45] \tat sun.nio.ch.IOUtil.read(IOUtil.java:197) ~[na:1.8.0_45] \tat sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380) ~[na:1.8.0_45] \tat org.apache.cassandra.streaming.messages.StreamMessage.deserialize(StreamMessage.java:54) ~[main/:na] \tat org.apache.cassandra.streaming.ConnectionHandler$IncomingMessageHandler.run(ConnectionHandler.java:261) ~[main/:na] \tat java.lang.Thread.run(Thread.java:745) [na:1.8.0_45]', 'ERROR [STREAM-OUT-/127.0.0.2] 2015-10-29 10:33:42,031 StreamSession.java:520 - [Stream #862cc220-7e28-11e5-b94f-5f64a052c605] Streaming error occurred']
> {code}
> This is because a node is crashed while it is receiving a stream from the decommissioned node.
> We should ignore this error and possibly handle this hung leaving state by restarting the decommission.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)