diff --git a/data-prepper-plugins/s3-source/src/main/java/org/opensearch/dataprepper/plugins/source/s3/SqsWorker.java b/data-prepper-plugins/s3-source/src/main/java/org/opensearch/dataprepper/plugins/source/s3/SqsWorker.java index 72578f5d29..d1b43687c9 100644 --- a/data-prepper-plugins/s3-source/src/main/java/org/opensearch/dataprepper/plugins/source/s3/SqsWorker.java +++ b/data-prepper-plugins/s3-source/src/main/java/org/opensearch/dataprepper/plugins/source/s3/SqsWorker.java @@ -339,7 +339,7 @@ private void deleteSqsMessages(final List 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(", "));