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: [email protected]
For additional commands, e-mail: [email protected]
