[jira] [Created] (CASSANDRA-10737) TestTopology.crash_during_decommission_test dtest sometimes fails due to interrupted streaming

["Joel Knighton (JIRA)" <ji...@apache.org>]

Joel Knighton created CASSANDRA-10737:
-----------------------------------------

             Summary: 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)