[jira] [Created] (FLUME-3273) Avro Flume source throws java.nio.channels.ClosedChannelException when a client is being disconnected

["Vyacheslav Kulakov (JIRA)" <ji...@apache.org>]

Vyacheslav Kulakov created FLUME-3273:
-----------------------------------------

             Summary: Avro Flume source throws java.nio.channels.ClosedChannelException when a client is being disconnected
                 Key: FLUME-3273
                 URL: https://issues.apache.org/jira/browse/FLUME-3273
             Project: Flume
          Issue Type: Bug
    Affects Versions: 1.8.0
         Environment: OS: Ubuntu 18.04
            Reporter: Vyacheslav Kulakov
         Attachments: flume-client.conf, flume.conf, flume.log

I configured the Avro source on my Flume instance and enabled compression for it. Then I sent some events with the avro-client (compression is enabled for the client too). The events were successfully transferred to sinks but in the File logs I found the following exception:

{{java.nio.channels.ClosedChannelException}}
{{at org.jboss.netty.channel.socket.nio.AbstractNioWorker.cleanUpWriteBuffer(AbstractNioWorker.java:433)}}
{{at org.jboss.netty.channel.socket.nio.AbstractNioWorker.writeFromUserCode(AbstractNioWorker.java:128)}}
{{at org.jboss.netty.channel.socket.nio.NioServerSocketPipelineSink.handleAcceptedSocket(NioServerSocketPipelineSink.java:99)}}
{{at org.jboss.netty.channel.socket.nio.NioServerSocketPipelineSink.eventSunk(NioServerSocketPipelineSink.java:36)}}
{{at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendDownstream(DefaultChannelPipeline.java:779)}}
{{at org.jboss.netty.channel.Channels.write(Channels.java:725)}}
{{at org.jboss.netty.channel.Channels.write(Channels.java:686)}}
{{at org.jboss.netty.handler.codec.compression.ZlibEncoder.finishEncode(ZlibEncoder.java:380)}}
{{at org.jboss.netty.handler.codec.compression.ZlibEncoder.handleDownstream(ZlibEncoder.java:316)}}

I think the following sequence of actions happened:
 # The client sent some events.
 # The server received those events.
 # The client closed connection.
 # The server got the connection close event.
 # The server tried to write ZLib checksum.
 # The server raised the exception because of already closed connection.

How can I suppress raising that exception?

Logs and configs for client and server in the attachment.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@flume.apache.org
For additional commands, e-mail: issues-help@flume.apache.org