You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2019/11/18 22:22:22 UTC

[GitHub] [pulsar] jm7647 opened a new issue #5690: Elasticsearch 5.x Sink connector incompatible

jm7647 opened a new issue #5690: Elasticsearch 5.x Sink connector incompatible
URL: https://github.com/apache/pulsar/issues/5690
 
 
   **Describe the bug**
   Works with ES 7.x version
   Fails with ES 5.x version
   
   Didn't try other versions.
   
   **To Reproduce**
   Steps to reproduce the behavior:
   1. Configure and run ES Sink
   2. See error
   
   {"error":{"root_cause":[{"type":"invalid_type_name_exception","reason":"Document mapping type name can't start with '_', found: [_doc]"}],"type":"invalid_type_name_exception","reason":"Document mapping type name can't start with '_', found: [_doc]"},"status":400}
                   at org.elasticsearch.client.RestClient$SyncResponseListener.get(RestClient.java:705) ~[?:?]
                   at org.elasticsearch.client.RestClient.performRequest(RestClient.java:235) ~[?:?]
                   at org.elasticsearch.client.RestClient.performRequest(RestClient.java:198) ~[?:?]
                   at org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:522) ~[?:?]
                   at org.elasticsearch.client.RestHighLevelClient.performRequestAndParseEntity(RestHighLevelClient.java:508) ~[?:?]
                   at org.elasticsearch.client.RestHighLevelClient.index(RestHighLevelClient.java:348) ~[?:?]
                   at org.apache.pulsar.io.elasticsearch.ElasticSearchSink.write(ElasticSearchSink.java:91) ~[?:?]
                   at org.apache.pulsar.functions.instance.JavaInstanceRunnable.sendOutputMessage(JavaInstanceRunnable.java:435) ~[org.apache.pulsar-pulsar-functions-instance-2.4.1.jar:?]
                   at org.apache.pulsar.functions.instance.JavaInstanceRunnable.processResult(JavaInstanceRunnable.java:418) ~[org.apache.pulsar-pulsar-functions-instance-2.4.1.jar:?]
                   at org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:272) [org.apache.pulsar-pulsar-functions-instance-2.4.1.jar:?]
                   at java.lang.Thread.run(Thread.java:748) [?:1.8.0_212]
           Caused by: org.elasticsearch.client.ResponseException: method [POST], host [http://135.91.35.218:9200], URI [/eventslist/_doc?timeout=1m], status line [HTTP/1.1 400 Bad Request]
   {"error":{"root_cause":[{"type":"invalid_type_name_exception","reason":"Document mapping type name can't start with '_', found: [_doc]"}],"type":"invalid_type_name_exception","reason":"Document mapping type name can't start with '_', found: [_doc]"},"status":400}
   
   
   **Expected behavior**
   
   **Screenshots**
   
   **Desktop (please complete the following information):**
    - OS: Ubuntu 16
   
   **Additional context**
   
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services