[FLINK-24323] Port ElasticSearch Sink to new Unified Sink API (FLIP-143) - ASF JIRA

XML

Word

Printable

JSON

Release Note:

Hide
`ElasticsearchXSinkBuilder` supersedes `ElasticsearchSink.Builder` and provides at-least-once writing with the new unified sink interface supporting both batch and streaming mode of DataStream API. To upgrade, please stop with savepoint.

For Elasticsearch 7 users that use the old ElasticsearchSink interface (org.apache.flink.streaming.connectors.elasticsearch7.ElasticsearchSink) and depend on their own elasticsearch-rest-high-level-client version, updating the client dependency to a version >= 7.14.0 is required due to internal changes.

Show
`ElasticsearchXSinkBuilder` supersedes `ElasticsearchSink.Builder` and provides at-least-once writing with the new unified sink interface supporting both batch and streaming mode of DataStream API. To upgrade, please stop with savepoint. For Elasticsearch 7 users that use the old ElasticsearchSink interface (org.apache.flink.streaming.connectors.elasticsearch7.ElasticsearchSink) and depend on their own elasticsearch-rest-high-level-client version, updating the client dependency to a version >= 7.14.0 is required due to internal changes.

We want to port the current ElasticSearch Sink to the new Unified Sink API as was done with the Kafka Sink.

1.	Create ElasticSearch 7 Sink	Resolved	Fabian Paul
2.	Create ElasticSearch 6.8 Sink	Resolved	Alexander Preuss
3.	Update Docs with new Sinks	Resolved	Alexander Preuss
4.	Integrate unified Elasticsearch 7 sink with Table API	Resolved	Alexander Preuss
5.	Deprecate Elasticsearch Sinkfunctions	Resolved	Alexander Preuss
6.	Update Elasticsearch Sinks to latest minor versions	Resolved	Alexander Preuss