Check if failedDeleteCount is positive before logging (opensearch-pro…

…ject#3686) Signed-off-by: Hai Yan <[email protected]>
asifsmohammed · Nov 27, 2023 · 6dc1d12 · 6dc1d12
1 parent 039741a
commit 6dc1d12
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ugins/s3-source/src/main/java/org/opensearch/dataprepper/plugins/source/s3/SqsWorker.java b/...ugins/s3-source/src/main/java/org/opensearch/dataprepper/plugins/source/s3/SqsWorker.java
@@ -339,7 +339,7 @@ private void deleteSqsMessages(final List<DeleteMessageBatchRequestEntry> delete
                 final int failedDeleteCount = deleteMessageBatchResponse.failed().size();
                 sqsMessagesDeleteFailedCounter.increment(failedDeleteCount);
 
-                if(LOG.isErrorEnabled()) {
+                if(LOG.isErrorEnabled() && failedDeleteCount > 0) {
                     final String failedMessages = deleteMessageBatchResponse.failed().stream()
                             .map(failed -> failed.toString())
                             .collect(Collectors.joining(", "));