I use TAILDIR sink in flume 1.7 to catch file changed in some folders 
and sink to HDFS, but after start flume,

some source runs well, some source causes Channel-closed error.

ERROR [PollableSourceRunner-TaildirSource-source-error] 
(org.apache.flume.source.taildir.TaildirSource.process:236) -Unable to 
tail files

java.lang.IllegalStateException: Channel closed [channel-cccc]. Due to 
java.io.EOFException: null

..

Caused by : java.io.EOFException

..

Sometimes,  souce folder has not been generated files, Does this the 
reason? How to avoid this problem?

Thanks.

Reply via email to