flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client
Date Wed, 23 May 2018 18:46:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487834#comment-16487834
] 

ASF GitHub Bot commented on FLINK-7386:
---------------------------------------

Github user cjolif commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6043#discussion_r190359413
  
    --- Diff: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java
---
    @@ -21,18 +21,56 @@
     import org.apache.flink.annotation.PublicEvolving;
     
     import org.elasticsearch.action.ActionRequest;
    +import org.elasticsearch.action.delete.DeleteRequest;
    +import org.elasticsearch.action.index.IndexRequest;
    +import org.elasticsearch.action.update.UpdateRequest;
     
     /**
    - * Users add multiple {@link ActionRequest ActionRequests} to a {@link RequestIndexer}
to prepare
    + * Users add multiple delete, index or update requests to a {@link RequestIndexer} to
prepare
      * them for sending to an Elasticsearch cluster.
      */
     @PublicEvolving
    -public interface RequestIndexer {
    +public abstract class RequestIndexer {
    --- End diff --
    
    done.


> Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client
> --------------------------------------------------------------------------------
>
>                 Key: FLINK-7386
>                 URL: https://issues.apache.org/jira/browse/FLINK-7386
>             Project: Flink
>          Issue Type: Improvement
>          Components: ElasticSearch Connector
>            Reporter: Dawid Wysakowicz
>            Assignee: Fang Yong
>            Priority: Critical
>             Fix For: 1.5.0
>
>
> In Elasticsearch 5.2.0 client the class {{BulkProcessor}} was refactored and has no longer
the method {{add(ActionRequest)}}.
> For more info see: https://github.com/elastic/elasticsearch/pull/20109



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message