Check if failedDeleteCount is positive before logging (#3686) (#3705)

Signed-off-by: Hai Yan <[email protected]> (cherry picked from commit 6dc1d12) Co-authored-by: Hai Yan <[email protected]>
opensearch-project · Nov 27, 2023 · b1f7aa8 · b1f7aa8
1 parent 250e1a0
commit b1f7aa8
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(", "));