Hi, Fidea.The ElasticsearchSinkFunction Class has already marked as deprecated[1], please try to use ElasticsearchSink Class.
Hope to help you. Best. Jiadong.Lu1. 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>