[pulsar] branch master updated: [pulsar-io-elastic-search] Change default document type for compliance with ES 7.x (#4322)

[sijie]

This is an automated email from the ASF dual-hosted git repository.

sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new a22af90  [pulsar-io-elastic-search] Change default document type for 
compliance with ES 7.x (#4322)
a22af90 is described below

commit a22af90629654416aa2023ccafa411ff2bfc527d
Author: Géraud Dugé de Bernonville <gerauds...@gmail.com>
AuthorDate: Sun May 26 14:16:51 2019 +0200

    [pulsar-io-elastic-search] Change default document type for compliance with 
ES 7.x (#4322)
    
    ### Motivation
    
    When running Elasticsearch sink on ES 7.0.1, message indexation fails with 
the following error :
    
    ```
    - Encountered exception in sink write:
    org.elasticsearch.ElasticsearchStatusException: Elasticsearch exception 
[type=illegal_argument_exception, reason=Rejecting mapping update to 
[geoloc-pulsar] as the final mapping would have more than 1 type: [_doc, doc]]
    ```
    
    According to 
https://www.elastic.co/guide/en/elasticsearch/reference/6.3/removal-of-types.html#_schedule_for_removal_of_mapping_types,
 the recommended document type to use is `_doc`.
    
    ### Modifications
    
    Replace document type `doc` with recommended value `_doc`.
---
 .../main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java
 
b/pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java
index 9552541..58eb30a 100644
--- 
a/pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java
+++ 
b/pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java
@@ -61,7 +61,7 @@ import org.elasticsearch.common.xcontent.XContentType;
 )
 public class ElasticSearchSink implements Sink<byte[]> {
 
-    protected static final String DOCUMENT = "doc";
+    protected static final String DOCUMENT = "_doc";
 
     private URL url;
     private RestHighLevelClient client;