Hi #C03G7LJTS2G Does anyone have experience using the Open Search flink connector? I am trying to follow the guide here and getting the following exception:

Caused by: java.io.IOException: Unable to parse response body for Response{requestLine=POST /_bulk?timeout=1m HTTP/1.1, host=<http://localhost:9200>, response=HTTP/1.1 200 OK}
	at org.opensearch.client.RestHighLevelClient$1.onSuccess(RestHighLevelClient.java:1942)
	at org.opensearch.client.RestClient$FailureTrackingResponseListener.onSuccess(RestClient.java:662)
	at org.opensearch.client.RestClient$1.completed(RestClient.java:396)
	at org.opensearch.client.RestClient$1.completed(RestClient.java:390)
....
Caused by: java.lang.NullPointerException
	at java.base/java.util.Objects.requireNonNull(Objects.java:208)
	at org.opensearch.action.DocWriteResponse.<init>(DocWriteResponse.java:140)
	at org.opensearch.action.index.IndexResponse.<init>(IndexResponse.java:67)

This seems to be known issue for https://github.com/elastic/elasticsearch/issues/84173 elastic search but I don’t have clear path for open search

Hi! I also have this problem for OpenSearch. How did you solve it eventually. I tried to add the relevant .jar (opensearch-2.6.0.jar, opensearch-rest-high-level-client-2.6.0.jar) to the Flink path. It did not work. I am still facing this issue.

The above fixed it for me: I am on: • Connector version

1.0.0-1.16

• Open Search

2.5.0

• Opensearch-rest-high-level-client

2.5.0

• And using docker container

2.5.0

for open search cluster

Hi! Thanks for the response! I did all that, but I might have made another small mistake or something. My colleague actually made it work.

Datastream