[FLINK-17623] Elasticsearch sink should support user resource cleanup

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.12.0
• Component/s: Connectors / ElasticSearch
• Labels: pull-request-available usability
• Assignee: Yun Wang
• Reporter: Yun Wang
• Created: 11/May/20 21:50
• Updated: 30/Nov/21 20:37
• Resolved: 15/Jun/20 03:17

Description

There should be a way for an ElasticsearchSinkFunction implementation to use resources with the same lifecycle as the Elasticsearch sink, for example, an RestHighLevelClient.

Currently there is no way to clean up such resources.

This can be achieved by either of the below:

1. Expose a `close()` method in the ElasticsearchSinkFunction interface, and invoke the close method from ElasticsearchSinkBase.close.
2. Make the ElasticsearchSink class extendable.

 

Issue Links

• links to: GitHub Pull Request #12619