java - 使用拦截器运行 flume agent 时出错

Question

我正在尝试使用 Linux 从终端运行自定义水槽代理。我正在研究 cloudera VM。命令运行水槽看起来像:

flume-ng agent --conf . -f spoolDirLocal2hdfs_memoryChannel.conflume.root.logger=DEBUG,console -n Agent5

带有拦截器的源代码如下:

Agent5.sources.spooldir-source.interceptors = i1
Agent5.sources.spooldir-source.interceptors.i1.type = org.flumefiles.flume.HtmlInterceptor$Buider

我已将我的 jar 文件放入 /usr/lib/hadoop/lib/ 和 /usr/lib/flume-ng/lib/。我还在 /usr/lib/flume-ng/plugins.d/ 创建了 plugins.d 并将 jar 放在那里。但是在运行 flume agent 时出现错误:

15/02/18 06:10:46 ERROR channel.ChannelProcessor: Builder class not found. Exception follows.
java.lang.ClassNotFoundException: org.intropro.flume.HtmlInterceptor$Buider
    at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
    at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
    at java.security.AccessController.doPrivileged(Native Method)

.....

我应该把我的 jar 文件放在哪里才能找到生成器？

Answer 1

将其放入FLUME_HOME/lib，然后重启flume。

如果这不起作用，请确保您的拦截器实际实现了 Builder 接口(interface)。这可能是另一个原因。