From 0740967d2122bd5dc1e4a985b6ea081ef527a039 Mon Sep 17 00:00:00 2001 From: Krishna Kondaka Date: Fri, 16 Aug 2024 19:31:19 +0000 Subject: [PATCH] Rebased to latest and cleanup messages Signed-off-by: Krishna Kondaka --- .../dataprepper/plugins/sink/opensearch/BulkRetryStrategy.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/BulkRetryStrategy.java b/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/BulkRetryStrategy.java index 3427bdad36..06ce19cc37 100644 --- a/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/BulkRetryStrategy.java +++ b/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/BulkRetryStrategy.java @@ -209,7 +209,7 @@ public void execute(final AccumulatingBulkRequest bulkRequest) throws Interrupte request = operationResponse.getBulkRequest(); exceptionMessage = operationResponse.getExceptionMessage(); if (delayMillis < 0) { - RuntimeException e = new RuntimeException(String.format("Index : %s, Number of retries reached the limit of max retries (configured value %d. Last exception message: %s)", maxRetries, exceptionMessage)); + RuntimeException e = new RuntimeException(String.format("Number of retries reached the limit of max retries (configured value %d. Last exception message: %s)", maxRetries, exceptionMessage)); handleFailures(request, null, e); break; }