OpenSearch hadoop error handling DLQ

OpenSearch Client Libraries
1

Versions (relevant - OpenSearch/Dashboard/Server OS/Browser):

Describe the issue:
OpenSearchSpark.saveJsonToOpenSearch(RDD[String], indexName) throws an exception when failing to write to opensearch.

Is there a way to get the broken row? I’m looking to save the particular row to a DLQ

The def returns Unit.

Configuration:

Relevant Logs or Screenshots:

2

This topic was automatically closed 60 days after the last reply. New replies are no longer allowed.