Hi, Fidea.
The ElasticsearchSinkFunction Class has already marked as deprecated[1], please try to use ElasticsearchSink Class.

Hope to help you.

Best.
Jiadong.Lu

1. https://github.com/apache/flink-connector-elasticsearch/blob/153b8fc23e14c03c4bacf2c24fbe0fee286ec6e2/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkFunction.java#L63 2. https://github.com/apache/flink-connector-elasticsearch/blob/153b8fc23e14c03c4bacf2c24fbe0fee286ec6e2/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSink.java#L56C14-L56C31

On 1/29/24 19:15, Fidea Lidea wrote:
Hi Team,

Could you please share with me a few example codes on  how to perform "updaterequest on elasticsearch using apache flink"
I.want to use |ElasticsearchSinkFunction| to perform updaterequest.

Thanks
Nida Shaikh
lideafidea...@gmail.com <mailto:lideafidea...@gmail.com>

Reply via email to