xxggmmxx 发表于 2015-9-17 08:47:42

flume ng: java.lang.IllegalStateException: Serializer has been closed

　　java.lang.IllegalStateException: Serializer has been closed
　　at org.apache.flume.serialization.LineDeserializer.ensureOpen(LineDeserializer.java:124)
　　at org.apache.flume.serialization.LineDeserializer.readEvents(LineDeserializer.java:88)
　　at org.apache.flume.client.avro.ReliableSpoolingFileEventReader.readEvents(ReliableSpoolingFileEventReader.java:221)
　　at org.apache.flume.source.SpoolDirectorySource$SpoolDirectoryRunnable.run(SpoolDirectorySource.java:160)
　　at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
　　
　　spool的目录下,已有文件已经处理了(后缀加上了.COMPLETED)了,然后目录下还有一个文件跟这个是同名的文件,在目录下存在
页: [1]
查看完整版本: flume ng: java.lang.IllegalStateException: Serializer has been closed