flume-filemonitor-source

flume-filemonitor-source copied to clipboard

监控的文件删除重新生成后该端点续传功能似乎有点力不从心了

1

你好，想请教一下您有没有遇到该断点续传功能所监控的文件删除后又重新生成后的情况。在实践中我发现当监控的文件正常有内容生成的时候，该功能会正常运行，并且flume进程挂掉的时候position.log也会记录结束时候的字节数。但是当监控的文件删除后，flume的控制台会打印出： java.io.FileNotFoundException: /home/hadoop/messages (No such file or directory) at java.io.RandomAccessFile.open(Native Method) at java.io.RandomAccessFile.(RandomAccessFile.java:233) at org.apache.flume.chiwei.filemonitor.FileMonitorSource$FileMonitorThread.run(FileMonitorSource.java:173) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:351) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at...

xiazi123

flume的source端如何配置

9

你这个项目如何引用，用eclipse打成jar包导入到flume的lib目录下行吗？还有就是该如何配置文件，能否给个例子，万分感谢啊。。。

xiazi123

不能按照条读取

2

这个是按照字节多条一次性的提交了一个event，event在处理时候还要按照换行符解析出来

NewsGitHub