[FLINK-7386] Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client

• Type: Improvement
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 1.6.0
• Component/s: Connectors / ElasticSearch
• Labels: pull-request-available

Release Note

Previous APIs in the Flink Elasticsearch Sink's RequestIndexer interface has been deprecated in favor of new signatures. When adding requests to the indexer, the requests now must be of type IndexRequest, DeleteRequest, or UpdateRequest, instead of the base ActionRequest.

• Assignee: Fang Yong
• Reporter: Dawid Wysakowicz
• Created: 08/Aug/17 08:03
• Updated: 19/Nov/18 08:23
• Resolved: 01/Aug/18 13:29

Description

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

Issue Links

• is required by: FLINK-9885 End-to-end test: Elasticsearch 6.x connector
• links to: GitHub Pull Request #4675
• links to: GitHub Pull Request #4675
• links to: GitHub Pull Request #6043
• links to: GitHub Pull Request #6043