The error just says that it cannot deliver the events. Do you have something (e.g. an avro source) listening for them on port 4545 of 221.130.18.211?
On Wed, 2012-08-08 at 19:13 +0800, Yanzhi.liu wrote: > hello: > I have a error for the flume configuration. > My configuration is: > agent_foo.sources = tailsource-1 tailsource > agent_foo.channels = memoryChannel-1 memoryChannel > agent_foo.sinks = Sink-1 Sink > agent_foo.sources.tailsource.type = exec > #com.chinacache.cpis.sources.CpisSource > agent_foo.sources.tailsource.command = tail -F /home/hadoop/text.txt > agent_foo.sources.tailsource.channels = memoryChannel > agent_foo.sources.tailsource.batchSize = 1 > agent_foo.channels.memoryChannel.type = file > agent_foo.channels.memoryChannel.checkpointDir=/home/hadoop/c > agent_foo.channels.memoryChannel.dataDirs=/home/hadoop/d > agent_foo.sinks.Sink.type=avro > agent_foo.sinks.Sink.channel=memoryChannel > agent_foo.sinks.Sink.hostname=221.130.18.211 > agent_foo.sinks.Sink.port=4545 > agent_foo.sinks.Sink.batch-size=1 > agent_foo.sources.tailsource-1.type = exec > #com.chinacache.cpis.sources.CpisSource > agent_foo.sources.tailsource-1.command = tail > -F /home/hadoop/hello.txt > agent_foo.sources.tailsource-1.channels = memoryChannel-1 > agent_foo.sources.tailsource-1.batchSize = 1 > agent_foo.channels.memoryChannel-1.type = file > agent_foo.channels.memoryChannel-1.checkpointDir=/home/hadoop/a > agent_foo.channels.memoryChannel-1.dataDirs=/home/hadoop/b > agent_foo.sinks.Sink-1.type=avro > agent_foo.sinks.Sink-1.channel=memoryChannel-1 > agent_foo.sinks.Sink-1.hostname=221.130.18.211 > agent_foo.sinks.Sink-1.port=4545 > agent_foo.sinks.Sink-1.batch-size=1 > But the log has error: > 2012-08-08 19:11:44,886 ERROR flume.SinkRunner: Unable to deliver > event. Exception follows. > java.lang.IllegalStateException: Channel closed > [channel=memoryChannel] > at > com.google.common.base.Preconditions.checkState(Preconditions.java:145) > at > org.apache.flume.channel.file.FileChannel.createTransaction(FileChannel.java:266) > at > org.apache.flume.channel.BasicChannelSemantics.getTransaction(BasicChannelSemantics.java:118) > at org.apache.flume.sink.AvroSink.process(AvroSink.java:277) > at > org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68) > at org.apache.flume.SinkRunner > $PollingRunner.run(SinkRunner.java:147) > at java.lang.Thread.run(Thread.java:662) > 2012-08-08 19:11:49,891 ERROR flume.SinkRunner: Unable to deliver > event. Exception follows. > java.lang.IllegalStateException: Channel closed > [channel=memoryChannel] > at > com.google.common.base.Preconditions.checkState(Preconditions.java:145) > at > org.apache.flume.channel.file.FileChannel.createTransaction(FileChannel.java:266) > at > org.apache.flume.channel.BasicChannelSemantics.getTransaction(BasicChannelSemantics.java:118) > at org.apache.flume.sink.AvroSink.process(AvroSink.java:277) > at > org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68) > at org.apache.flume.SinkRunner > $PollingRunner.run(SinkRunner.java:147) > at java.lang.Thread.run(Thread.java:662) > I want to know how to solve the problem. > Thank you very much! > My name > Yanzhi Liu > >
