search

crowdrec / idomaar

CrowdRec reference framework
Apache License 2.0
32 stars 12 forks source link

Flume error on agent startup #56

Closed davidemalagoli closed 9 years ago

davidemalagoli commented 9 years ago

02 Sep 2015 08:39:47,444 INFO conf-file-poller-0 - context={ parameters:{topic=recommendation-requests-92-83941, brokerList=192.168.22.5:9092, batchSize=5, type=org.apache.flume.sink.kafka.KafkaSink, channel=c_rec} } 02 Sep 2015 08:39:47,448 ERROR conf-file-poller-0 - Unhandled error java.lang.NoSuchMethodError: org.apache.flume.instrumentation.SinkCounter.(Ljava/lang/String;[Ljava/lang/String;)V at org.apache.flume.instrumentation.kafka.KafkaSinkCounter.(KafkaSinkCounter.java:34) at org.apache.flume.sink.kafka.KafkaSink.configure(KafkaSink.java:218) at org.apache.flume.conf.Configurables.configure(Configurables.java:41) at org.apache.flume.node.AbstractConfigurationProvider.loadSinks(AbstractConfigurationProvider.java:413) at org.apache.flume.node.AbstractConfigurationProvider.getConfiguration(AbstractConfigurationProvider.java:98) at org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable.run(PollingPropertiesFileConfigurationProvider.java:140) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304) 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 java.lang.Thread.run(Thread.java:745)