Skip to content

[BUG] Invalid document version from events is still included in opensearch bulk requests #6601

@graytaylor0

Description

@graytaylor0

Describe the bug
Using external versioning with document_version and document_version_type in the opensearch sink with invalid version fields sends the event to DLQ, but then also includes it in the bulk request.

Expected behavior
Send the event to DLQ, then do not add it to the bulk request:

logFailureForDlqObjects(List.of(createDlqObjectFromEvent(event, indexName, errorMessage)), e);

Screenshots
If applicable, add screenshots to help explain your problem.

Environment (please complete the following information):

  • OS: [e.g. Ubuntu 20.04 LTS]
  • Version [e.g. 22]

Additional context
Add any other context about the problem here.

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't working

    Type

    No type

    Projects

    Status

    Done

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions