From b9f360ca40adb29dd892a3998d71f0a75f88fb4c Mon Sep 17 00:00:00 2001 From: Hai Yan <8153134+oeyh@users.noreply.github.com> Date: Mon, 27 Nov 2023 14:44:00 -0600 Subject: [PATCH] Check if failedDeleteCount is positive before logging (#3686) Signed-off-by: Hai Yan (cherry picked from commit 6dc1d12a4b84ade389d7cc311799363e3ea3114d) --- .../org/opensearch/dataprepper/plugins/source/s3/SqsWorker.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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(", "));