ElasticsearchSink2

ElasticsearchSink2 copied to clipboard

TransportClient adaptions for use with Elasticsearch 5.X aviable in the future?

3

Hello, as I read the major version of the TransportClient must be the as the major version of Elasticsearch. I am highly interested to use this sink together with ES...

ccentner

the error log shows: ``` [ERROR - org.apache.flume.lifecycle.LifecycleSupervisor$MonitorRunnable.run(LifecycleSupervisor.java:251)] Unable to start SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor@269c7f70 counterGroup:{ name:null counters:{} } } - Exception follows. java.lang.NoSuchFieldError: LUCENE_5_3_1 ``` the elasticsearch 2.2.1 uses lucene...

glh1991

why default indexName in es2.3.3，has yyyy-mm-dd？

1

mymaoqiu

Update to ElasticSearch 2.1

4

Update version of elasticsearch to avoid java.lang.NoSuchFieldError: LUCENE_5_3_1 when using elasticsearch 2.1.0.

ollie314

Could not instantiate event serializer

1

I am trying with flume 1.6 with elastic search 2.3. Everything is working gradle perspective. But while executing the flume, it is producing the serializer error. java.lang.IllegalArgumentException: org.apache.flume.sink.elasticsearch.ElasticSearchDynamicSerializer is not...

vikasreddy89

**write data:** { "action_type": "media", "test_double": "2131312312", "media_type": "mobile", "created_timestamp": "2016-09-07 09:42:57", "is_incr": "yes", "browser_lang": "OTHER", "device_mobile": "15559850392", "device_os_ver": "Unknown", "media_code": "bj001", "test_long": 12313123, "browser_ver": "sss", "loc_ip": "61.233.69.82", "device_mac": "00:70:A4:00:00:5C",...

mymaoqiu

Hi, i'm using elasticsearch 2.4.0, cloudera-manager 5.8.0 I copied elasticsearch-2.4.0.jar and lucene-core-5.5.2.jar to flume plugins. I changed some flume jars for elastic(i saw errors about it) t-digest-3.0.jar jsr166e-1.1.0.jar guava-18.0.jar And...

gfrntz

is build possible without internet access ?

2

mrchenjunjie

24 Jun 2016 16:36:16,138 ERROR [lifecycleSupervisor-1-1](org.apache.flume.lifecycle.LifecycleSupervisor$MonitorRunnable.run:253) - Unable to start SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor@161dbb35 counterGroup:{ name:null counters:{} } } - Exception follows. java.lang.IncompatibleClassChangeError: Found interface org.elasticsearch.common.settings.Settings, but class was expected at...

lovewanli

ClassNotFoundException: TimeBasedIndexNameBuilder

9

Hey, First of all thank you for creating this. If i can get it working it will be a great help. The issue I have on restarting flume is this:...

pricecarl