Skip to content

Fix documentErrors metric incorrectly counting version conflict error…#6758

Open
Keyur-S-Patel wants to merge 1 commit intoopensearch-project:mainfrom
Keyur-S-Patel:fix/exclude-version-conflict-from-document-errors-5376
Open

Fix documentErrors metric incorrectly counting version conflict error…#6758
Keyur-S-Patel wants to merge 1 commit intoopensearch-project:mainfrom
Keyur-S-Patel:fix/exclude-version-conflict-from-document-errors-5376

Conversation

@Keyur-S-Patel
Copy link
Copy Markdown
Contributor

Description

In BulkRetryStrategy.handleFailures(), the documentErrorsCounter was being incremented for all item-level errors, including version conflict errors. Version conflict errors are not true document errors — they indicate the latest version of the document already exists in OpenSearch and are not sent to the DLQ. This caused the documentErrors metric to be inflated, creating a confusing user experience.

This change moves documentErrorsCounter.increment() and getDocumentStatusCounter().increment() into the else branch so they only fire for actual non-retryable failures, skipping version conflicts. This matches the existing behavior already present in createBulkRequestForRetry(). A unit test was added to verify that version conflicts only increment documentsVersionConflictErrors and not documentErrors.

Issues Resolved

Resolves #5376

Check List

  • New functionality includes testing.
  • New functionality has a documentation issue. Please link to it in this PR.
  • New functionality has javadoc added
  • Commits are signed with a real name per the DCO

By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.
For more information on following Developer Certificate of Origin and signing off your commits, please check [here](https://github.com/opensearch-project/data-prepper/blob/main/CONTRIBUTING.md).

opensearch-project#5376)

In BulkRetryStrategy.handleFailures(), documentErrorsCounter was
incremented for all item errors including version conflicts. Version
conflicts are not true errors — they indicate the latest document
already exists in OpenSearch and are not sent to DLQ.

Moved documentErrorsCounter.increment() and getDocumentStatusCounter()
into the else branch so they only fire for actual non-retryable
failures, matching the existing behavior in createBulkRequestForRetry().

Added unit test to verify version conflicts increment only the
documentsVersionConflictErrors metric and not documentErrors.

Signed-off-by: Keyur-S-Patel <keyurpatel.opensource@gmail.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[BUG] Do not report documentVersionConflictErrors in documentErrors metric in the OpenSearch sink

1 participant