GitHub user fpompermaier opened a pull request:
https://github.com/apache/flink/pull/5372
[FLINK-8101] [es connector] Elasticsearch 6.x (and 5.3+) Flink connector
## Purpose of the change : implementation of Flink ES connector (5.3+)
See https://issues.apache.org/jira/browse/FLINK-8101 and
https://issues.apache.org/jira/browse/FLINK-7386
## Brief change log
- Changed "standard" ES connector structor, mainly because there's
incompatibility between TransportClient and RestClient and, From ES 5.3+
embedded Node environment is not supported anymore. A running test ES cluster
is needed to properly test the code
## Verifying this change
- Set up an ES cluster and properly change ES_TEST_HOST, ES_TEST_PORT and
CLUSTER_NAME in the tests (or viceversa: set up a localhost ES cluster
listening on http port 9200 with cluster name "test-cluster")
## Does this pull request potentially affect one of the following parts:
- Flink ES connectors
## Documentation
- Does this pull request introduce a new feature? yes
- If yes, how is the feature documented? Javadocs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fpompermaier/flink master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/5372.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #5372
----
commit eaf878de646d90c5b821e0d3b0964fa311f8ac42
Author: Flavio Pompermaier <f.pompermaier@...>
Date: 2018-01-26T14:26:52Z
First draft of ES 6 connector
----
---
