From b1f7aa864515c5831d3acd4b26fc253d0d69eff2 Mon Sep 17 00:00:00 2001 From: "opensearch-trigger-bot[bot]" <98922864+opensearch-trigger-bot[bot]@users.noreply.github.com> Date: Mon, 27 Nov 2023 16:01:30 -0600 Subject: [PATCH] Check if failedDeleteCount is positive before logging (#3686) (#3705) Signed-off-by: Hai Yan (cherry picked from commit 6dc1d12a4b84ade389d7cc311799363e3ea3114d) Co-authored-by: Hai Yan <8153134+oeyh@users.noreply.github.com> --- .../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(", "));