You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Describe the bug update, upsert, and delete bulk actions in the opensearch sink requires knowing the document_id of the document to update or delete. However, if document_id is not provided in the opensearch sink with one of these actions being used, the following NPE is hit when converting the failed document to a DLQ object
Caused by: java.lang.NullPointerException
at org.opensearch.dataprepper.plugins.sink.opensearch.dlq.FailedBulkOperationConverter.convertDocumentToGenericMap(FailedBulkOperationConverter.java:64) ~[opensearch-2.6.1.jar:?]
at org.opensearch.dataprepper.plugins.sink.opensearch.dlq.FailedBulkOperationConverter.convertToDlqObject(FailedBulkOperationConverter.java:38) ~[opensearch-2.6.1.jar:?]
at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?]
Expected behavior
Do not crash the pipeline and send the document to DLQ without any document_id
Screenshots
If applicable, add screenshots to help explain your problem.
Environment (please complete the following information):
Describe the bug
update
,upsert
, anddelete
bulk actions in the opensearch sink requires knowing thedocument_id
of the document to update or delete. However, ifdocument_id
is not provided in theopensearch
sink with one of these actions being used, the following NPE is hit when converting the failed document to a DLQ objectExpected behavior
Do not crash the pipeline and send the document to DLQ without any document_id
Screenshots
If applicable, add screenshots to help explain your problem.
Environment (please complete the following information):
Additional context
Related to #3933
The text was updated successfully, but these errors were encountered: