Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
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:
- Expose a `close()` method in the ElasticsearchSinkFunction interface, and invoke the close method from ElasticsearchSinkBase.close.
- Make the ElasticsearchSink class extendable.
Attachments
Issue Links
- links to