flume twitter流

h9vpoimq  于 2021-06-01  发布在  Hadoop
关注(0)|答案(1)|浏览(463)

我试图执行flume从twitter流获取数据,但是在执行flume时收到了这个错误。
[错误-org.apache.flume.lifecyclesupervisor$monitorUnnable.run(lifecyclesupervisor。java:253)]无法启动eventdrivensourcerunner:{source:com.cloudera.flume.source.twittersource{name:twitter,state:idle}}-异常如下。java.lang.nosuchmethoderror:twitter4j.twitterstream.addlistener(ltwitter4j/streamlistener;)v在com.cloudera.flume.source.twittersource.start(twittersource。java:140)在org.apache.flume.source.eventdrivensourcerunner.start(eventdrivensourcerunner。java:44)在org.apache.flume.lifecyclesupervisor.lifecyclesupervisor$monitorUnnable.run(lifecyclesupervisor。java:251)在java.util.concurrent.executors$runnableadapter.call(executors。java:471)在java.util.concurrent.futuretask.runandreset(futuretask。java:304)在java.util.concurrent.scheduledthreadpoolexecutor$scheduledfuturetask.access$301(scheduledthreadpoolexecutor。java:178)在java.util.concurrent.scheduledthreadpoolexecutor$scheduledfuturetask.run(scheduledthreadpoolexecutor。java:293)在java.util.concurrent.threadpoolexecutor.runworker(threadpoolexecutor。java:1145)在java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor。java:615)在java.lang.thread.run(线程。java:745)
我是flume的初学者,在cloudera quickstart中工作。在搜索解决方案时,据说要安装maven,然后从那里构建flume快照jar文件,但我不知道如何在cloudera quickstart中安装maven。有没有关于如何纠正这个错误的帮助,请告诉我,我已经被困在这里一个星期了。

pjngdqdw

pjngdqdw1#

找到了解决方案:冲突是由twitter4j文件和flume快照jar引起的。因此,我用jarx更改了twitter4jjar的文件扩展名,从而重命名了twitter4jjar。通过阅读本文,我做的另一件事是将flume快照放在下面的层次结构中/usr/lib/flume ng/lib/plugins.d/flumesnapshot并在var目录中遵循相同的模式。

相关问题