Hi,
I am sending the error message below; java.lang.IllegalArgumentException: No support for request [org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest@3ed05d8b] at org.elasticsearch.action.bulk.BulkRequest.add(BulkRequest.java:107) ~[elasticsearch-2.3.5.jar:2.3.5] at org.elasticsearch.action.bulk.BulkProcessor.internalAdd(BulkProcessor.java:284) ~[elasticsearch-2.3.5.jar:2.3.5] at org.elasticsearch.action.bulk.BulkProcessor.add(BulkProcessor.java:268) ~[elasticsearch-2.3.5.jar:2.3.5] at org.elasticsearch.action.bulk.BulkProcessor.add(BulkProcessor.java:264) ~[elasticsearch-2.3.5.jar:2.3.5] at org.apache.flink.streaming.connectors.elasticsearch2.BulkProcessorIndexer.add(BulkProcessorIndexer.java:32) ~[flink-connector-elasticsearch2_2.10-1.2-20160926.041955-45.jar:1.2-SNAPSHOT] at sink.ESSink.process(ESSink.java:77) ~[classes/:?] at sink.ESSink.process(ESSink.java:25) ~[classes/:?] at org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink.invoke(ElasticsearchSink.java:232) ~[flink-connector-elasticsearch2_2.10-1.2-20160926.041955-45.jar:1.2-SNAPSHOT] at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:39) ~[flink-streaming-java_2.10-1.1.1.jar:1.1.1] at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:176) ~[flink-streaming-java_2.10-1.1.1.jar:1.1.1] at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:66) ~[flink-streaming-java_2.10-1.1.1.jar:1.1.1] at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:266) ~[flink-streaming-java_2.10-1.1.1.jar:1.1.1] at org.apache.flink.runtime.taskmanager.Task.run(Task.java:584) [flink-runtime_2.10-1.1.1.jar:1.1.1] at java.lang.Thread.run(Thread.java:745) [?:1.8.0_101] 09/26/2016 16:14:05 Sink: Unnamed(1/1) switched to FAILED We try to add mapping request to elastic search. We cannot access to client attribute (it is private) in elasticsearch class. Is there any way to overcome this problem. Thanks, Ozan ________________________________ Gönderen: Till Rohrmann <trohrm...@apache.org> Gönderildi: 26 Eylül 2016 Pazartesi 13:30:34 Kime: dev@flink.apache.org Bilgi: Aljoscha Krettek Konu: Re: No support for request PutMappingRequest Hi Ozan, I'm not super experienced with Flink's elasticsearch connector, but could you post the complete stack trace to figure out where the problem comes from? I've also pulled in Aljoscha, the original author of the elasticsearch sink. Maybe he can give you a detailed answer. Cheers, Till On Fri, Sep 23, 2016 at 1:41 PM, Ozan DENİZ <ozande...@outlook.com> wrote: > Hi everyone, > > > We are trying to use elasticsearch (2.x) connector for Flink application. > However, we encounter a problem when we try to add mapping to elasticsearch > index. > > > The error message is below when we run the Flink application. > > > No support for request [org.elasticsearch.action. > admin.indices.mapping.put.PutMappingRequest] > > > We are using "putMappingRequest" function for mapping. In Flink, is there > any way to add mapping to indexes in elasticsearch? > > > If not, can we contribute for adding mapping feature to elasticsearch > connector? >
