[jira] [Commented] (CASSANDRA-13431) Streaming error occurred org.apache.cassandra.io.FSReadError: java.io.IOException: Broken pipe

2017-10-10 Thread Varun Gupta (JIRA) 

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

Varun Gupta commented on CASSANDRA-13431:
-

I am seeing similar error at 3.0.14 as well.

> Streaming error occurred org.apache.cassandra.io.FSReadError: 
> java.io.IOException: Broken pipe
> --
>
> Key: CASSANDRA-13431
> URL: https://issues.apache.org/jira/browse/CASSANDRA-13431
> Project: Cassandra
>  Issue Type: Bug
>  Components: Streaming and Messaging
> Environment: ubuntu, cassandra 2.2.7, AWS EC2
>Reporter: krish
>  Labels: features, patch, performance
> Fix For: 2.2.7
>
>
> I am trying to add a node to the cluster. 
> Adding new node to cluster fails with broken pipe. cassandra fails after 
> starting with in 2 mints. 
> removed the node from the ring. Adding back fails. 
> OS info:  4.4.0-59-generic #80-Ubuntu SMP x86_64 x86_64 x86_64 GNU/Linux.
> ERROR [STREAM-OUT-/123.120.56.71] 2017-04-10 23:46:15,410 
> StreamSession.java:532 - [Stream #cbb7a150-1e47-11e7-a556-a98ec456f4de] 
> Streaming error occurred
> org.apache.cassandra.io.FSReadError: java.io.IOException: Broken pipe
> at 
> org.apache.cassandra.io.util.ChannelProxy.transferTo(ChannelProxy.java:144) 
> ~[apache-cassandra-2.2.7.jar:2.2.7]
> at 
> org.apache.cassandra.streaming.compress.CompressedStreamWriter$1.apply(CompressedStreamWriter.java:91)
>  ~[apache-cassandra-2.2.7.jar:2.2.
>   7]
> at 
> org.apache.cassandra.streaming.compress.CompressedStreamWriter$1.apply(CompressedStreamWriter.java:88)
>  ~[apache-cassandra-2.2.7.jar:2.2.
>   7]
> at 
> org.apache.cassandra.io.util.BufferedDataOutputStreamPlus.applyToChannel(BufferedDataOutputStreamPlus.java:297)
>  ~[apache-cassandra-2.2.7  
> .jar:2.2.7]
> at 
> org.apache.cassandra.streaming.compress.CompressedStreamWriter.write(CompressedStreamWriter.java:87)
>  ~[apache-cassandra-2.2.7.jar:2.2.7]
> at 
> org.apache.cassandra.streaming.messages.OutgoingFileMessage.serialize(OutgoingFileMessage.java:90)
>  ~[apache-cassandra-2.2.7.jar:2.2.7]
> at 
> org.apache.cassandra.streaming.messages.OutgoingFileMessage$1.serialize(OutgoingFileMessage.java:48)
>  ~[apache-cassandra-2.2.7.jar:2.2.7]
> at 
> org.apache.cassandra.streaming.messages.OutgoingFileMessage$1.serialize(OutgoingFileMessage.java:40)
>  ~[apache-cassandra-2.2.7.jar:2.2.7]
> at 
> org.apache.cassandra.streaming.messages.StreamMessage.serialize(StreamMessage.java:47)
>  ~[apache-cassandra-2.2.7.jar:2.2.7]
> at 
> org.apache.cassandra.streaming.ConnectionHandler$OutgoingMessageHandler.sendMessage(ConnectionHandler.java:389)
>  ~[apache-cassandra-2.2.7  
> .jar:2.2.7]
> at 
> org.apache.cassandra.streaming.ConnectionHandler$OutgoingMessageHandler.run(ConnectionHandler.java:361)
>  ~[apache-cassandra-2.2.7.jar:2.2.7]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_101]
> Caused by: java.io.IOException: Broken pipe
> at sun.nio.ch.FileChannelImpl.transferTo0(Native Method) 
> ~[na:1.8.0_101]
> at 
> sun.nio.ch.FileChannelImpl.transferToDirectlyInternal(FileChannelImpl.java:428)
>  ~[na:1.8.0_101]
> at 
> sun.nio.ch.FileChannelImpl.transferToDirectly(FileChannelImpl.java:493) 
> ~[na:1.8.0_101]
> at sun.nio.ch.FileChannelImpl.transferTo(FileChannelImpl.java:608) 
> ~[na:1.8.0_101]
> at 
> org.apache.cassandra.io.util.ChannelProxy.transferTo(ChannelProxy.java:140) 
> ~[apache-cassandra-2.2.7.jar:2.2.7]
> ... 11 common frames omitted
> INFO  [STREAM-OUT-/123.120.56.71] 2017-04-10 23:46:15,424 
> StreamResultFuture.java:183 - [Stream #cbb7a150-1e47-11e7-a556-a98ec456f4de] 
> Session with /  123.120.56.71 
> is complete
> WARN  [STREAM-OUT-/123.120.56.71] 2017-04-10 23:46:15,425 
> StreamResultFuture.java:210 - [Stream #cbb7a150-1e47-11e7-a556-a98ec456f4de] 
> Stream failed



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

-
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org

[jira] [Commented] (CASSANDRA-13431) Streaming error occurred org.apache.cassandra.io.FSReadError: java.io.IOException: Broken pipe

2017-04-13 Thread Paulo Motta (JIRA) 

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

Paulo Motta commented on CASSANDRA-13431:
-

broken pipe means the other end closed the connection, what was the streaming 
error on {{123.120.56.71}} ?

> Streaming error occurred org.apache.cassandra.io.FSReadError: 
> java.io.IOException: Broken pipe
> --
>
> Key: CASSANDRA-13431
> URL: https://issues.apache.org/jira/browse/CASSANDRA-13431
> Project: Cassandra
>  Issue Type: Bug
>  Components: Streaming and Messaging
> Environment: ubuntu, cassandra 2.2.7, AWS EC2
>Reporter: krish
>  Labels: features, patch, performance
> Fix For: 2.2.7
>
>
> I am trying to add a node to the cluster. 
> Adding new node to cluster fails with broken pipe. cassandra fails after 
> starting with in 2 mints. 
> removed the node from the ring. Adding back fails. 
> OS info:  4.4.0-59-generic #80-Ubuntu SMP x86_64 x86_64 x86_64 GNU/Linux.
> ERROR [STREAM-OUT-/123.120.56.71] 2017-04-10 23:46:15,410 
> StreamSession.java:532 - [Stream #cbb7a150-1e47-11e7-a556-a98ec456f4de] 
> Streaming error occurred
> org.apache.cassandra.io.FSReadError: java.io.IOException: Broken pipe
> at 
> org.apache.cassandra.io.util.ChannelProxy.transferTo(ChannelProxy.java:144) 
> ~[apache-cassandra-2.2.7.jar:2.2.7]
> at 
> org.apache.cassandra.streaming.compress.CompressedStreamWriter$1.apply(CompressedStreamWriter.java:91)
>  ~[apache-cassandra-2.2.7.jar:2.2.
>   7]
> at 
> org.apache.cassandra.streaming.compress.CompressedStreamWriter$1.apply(CompressedStreamWriter.java:88)
>  ~[apache-cassandra-2.2.7.jar:2.2.
>   7]
> at 
> org.apache.cassandra.io.util.BufferedDataOutputStreamPlus.applyToChannel(BufferedDataOutputStreamPlus.java:297)
>  ~[apache-cassandra-2.2.7  
> .jar:2.2.7]
> at 
> org.apache.cassandra.streaming.compress.CompressedStreamWriter.write(CompressedStreamWriter.java:87)
>  ~[apache-cassandra-2.2.7.jar:2.2.7]
> at 
> org.apache.cassandra.streaming.messages.OutgoingFileMessage.serialize(OutgoingFileMessage.java:90)
>  ~[apache-cassandra-2.2.7.jar:2.2.7]
> at 
> org.apache.cassandra.streaming.messages.OutgoingFileMessage$1.serialize(OutgoingFileMessage.java:48)
>  ~[apache-cassandra-2.2.7.jar:2.2.7]
> at 
> org.apache.cassandra.streaming.messages.OutgoingFileMessage$1.serialize(OutgoingFileMessage.java:40)
>  ~[apache-cassandra-2.2.7.jar:2.2.7]
> at 
> org.apache.cassandra.streaming.messages.StreamMessage.serialize(StreamMessage.java:47)
>  ~[apache-cassandra-2.2.7.jar:2.2.7]
> at 
> org.apache.cassandra.streaming.ConnectionHandler$OutgoingMessageHandler.sendMessage(ConnectionHandler.java:389)
>  ~[apache-cassandra-2.2.7  
> .jar:2.2.7]
> at 
> org.apache.cassandra.streaming.ConnectionHandler$OutgoingMessageHandler.run(ConnectionHandler.java:361)
>  ~[apache-cassandra-2.2.7.jar:2.2.7]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_101]
> Caused by: java.io.IOException: Broken pipe
> at sun.nio.ch.FileChannelImpl.transferTo0(Native Method) 
> ~[na:1.8.0_101]
> at 
> sun.nio.ch.FileChannelImpl.transferToDirectlyInternal(FileChannelImpl.java:428)
>  ~[na:1.8.0_101]
> at 
> sun.nio.ch.FileChannelImpl.transferToDirectly(FileChannelImpl.java:493) 
> ~[na:1.8.0_101]
> at sun.nio.ch.FileChannelImpl.transferTo(FileChannelImpl.java:608) 
> ~[na:1.8.0_101]
> at 
> org.apache.cassandra.io.util.ChannelProxy.transferTo(ChannelProxy.java:140) 
> ~[apache-cassandra-2.2.7.jar:2.2.7]
> ... 11 common frames omitted
> INFO  [STREAM-OUT-/123.120.56.71] 2017-04-10 23:46:15,424 
> StreamResultFuture.java:183 - [Stream #cbb7a150-1e47-11e7-a556-a98ec456f4de] 
> Session with /  123.120.56.71 
> is complete
> WARN  [STREAM-OUT-/123.120.56.71] 2017-04-10 23:46:15,425 
> StreamResultFuture.java:210 - [Stream #cbb7a150-1e47-11e7-a556-a98ec456f4de] 
> Stream failed



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)