New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[FLINK-8101] [es connector] Elasticsearch 6.x (and 5.3+) Flink connector #5372

Closed

fpompermaier wants to merge 1 commit into apache:master from fpompermaier:master

Contributor

fpompermaier commented Jan 26, 2018

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


          First draft of ES 6 connector

eaf878d

Contributor Author

fpompermaier commented Jan 30, 2018

Closed in favour of more advanced implementation of PR #5374 or #4675.
This PR was just a draft to start a discussion in https://issues.apache.org/jira/browse/FLINK-8101

fpompermaier closed this

rmetzger added the component=Connectors/ElasticSearch label

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment