You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flume.apache.org by Mohit Anchlia <mo...@gmail.com> on 2012/06/16 02:21:25 UTC

Server error

Whenever I send request to flume ng source it works but I always get error
on the server:

12/06/15 17:20:26 INFO ipc.NettyServer: [id: 0x48082751, /
160.28.168.251:2747 => /160.18.62.202:41414] CONNECTED: /160.28.168.251:2747
12/06/15 17:20:27 WARN ipc.NettyServer: Unexpected exception from
downstream.
java.io.IOException: Connection reset by peer
        at sun.nio.ch.FileDispatcher.read0(Native Method)
        at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:21)
        at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:202)
        at sun.nio.ch.IOUtil.read(IOUtil.java:169)
        at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:243)
        at
org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:323)
        at
org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:282)
        at
org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:202)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:662)
12/06/15 17:20:27 INFO ipc.NettyServer: [id: 0x48082751, /
160.28.168.251:2747 :> /160.18.62.202:41414] DISCONNECTED
12/06/15 17:20:27 INFO ipc.NettyServer: [id: 0x48082751, /
160.28.168.251:2747 :> /160.18.62.202:41414] UNBOUND
12/06/15 17:20:27 INFO ipc.NettyServer: [id: 0x48082751, /
160.28.168.251:2747 :> /160.18.62.202:41414] CLOSED
12/06/15 17:20:28 INFO hdfs.BucketWriter: Creating
hdfs://dsdb1:54310/flume/'dslg1'/FlumeData.1339806027954.tmp
12/06/15 17:20:59 INFO hdfs.BucketWriter: Renaming
hdfs://dsdb1:54310/flume/'dslg1'/FlumeData.1339806027954.tmp to
hdfs://dsdb1:54310/flume/'dslg1'/FlumeData.1339806027954
12/06/15 17:21:11 INFO ipc.NettyServer: [id: 0x018f6559, /
160.28.168.251:2757 => /160.18.62.202:41414] OPEN
12/06/15 17:21:11 INFO ipc.NettyServer: [id: 0x018f6559, /
160.28.168.251:2757 => /160.18.62.202:41414] BOUND: /160.18.62.202:41414
12/06/15 17:21:11 INFO ipc.NettyServer: [id: 0x018f6559, /
160.28.168.251:2757 => /160.18.62.202:41414] CONNECTED: /160.28.168.251:2757
12/06/15 17:21:12 WARN ipc.NettyServer: Unexpected exception from
downstream.
java.io.IOException: Connection reset by peer
        at sun.nio.ch.FileDispatcher.read0(Native Method)
        at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:21)
        at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:202)
        at sun.nio.ch.IOUtil.read(IOUtil.java:169)
        at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:243)
        at
org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:323)
        at
org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:282)
        at
org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:202)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:662)
12/06/15 17:21:12 INFO ipc.NettyServer: [id: 0x018f6559, /
160.28.168.251:2757 :> /160.18.62.202:41414] DISCONNECTED