本帖最后由 J20_果农 于 2017-8-24 19:15 编辑
版本flume1.7.0 , es 5.5.2,es 5.4.3
已经把es下的lib所有jar都扔到flume下的lib
两个版本都试了 ,一直报错 , 大神们帮忙看一下,谢谢!
错误信息:
2017-08-24 17:27:13,517 (conf-file-poller-0) [ERROR - org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable.run(PollingPropertiesFileConfigurationProvider.java:146)] Failed to start agent because dependencies were not found in classpath. Error follows.
java.lang.NoClassDefFoundError: org/elasticsearch/common/io/BytesStream
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:190)
at org.apache.flume.sink.elasticsearch.ElasticSearchSink.configure(ElasticSearchSink.java:287)
at org.apache.flume.conf.Configurables.configure(Configurables.java:41)
at org.apache.flume.node.AbstractConfigurationProvider.loadSinks(AbstractConfigurationProvider.java:411)
at org.apache.flume.node.AbstractConfigurationProvider.getConfiguration(AbstractConfigurationProvider.java:102)
at org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable.run(PollingPropertiesFileConfigurationProvider.java:141)
[mw_shl_code=applescript,true]agent5.sinks.k1.channel = c1
agent5.sinks.k1.type=org.apache.flume.sink.elasticsearch.ElasticSearchSink
agent5.sinks.k1.hostNames=10.30.5.2:9300,10.30.5.3:9300,10.30.5.4:9300
agent5.sinks.k1.indexName=kafka_log
agent5.sinks.k1.indexType = logs
agent5.sinks.k1.clusterName = a-cluster
agent5.sinks.k1.ttl = 5d
agent5.sinks.k1.batchSize = 4000
agent5.sinks.k1.serializer = org.apache.flume.sink.elasticsearch.ElasticSearchDynamicSerializer[/mw_shl_code]
|
|