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)
