Skip to content

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

Closed

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.

Activity

  1. dlvenable commented on Mar 3, 2026

    @dlvenable
    Member

    It looks like we do a pre-validation before the bulk request. Then it still goes into the bulk request.

    I'm going to guess it ends up in the DLQ twice. @graytaylor0 , Is that the case?

  2. graytaylor0 commented on Mar 9, 2026

    @graytaylor0
    MemberAuthor

    @dlvenable Yes it goes into the DLQ twice, but the bigger issue is that opensearch had a bug that caused one invalid version document to fail the entire bulk request so the entire bulk request gets sent to DLQ

  3. added this to the v2.15 milestone on Mar 18, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't working

    Type

    No type

    Projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions