From 29f2e0df46f4e7c86632cd82bea4c46a254382db Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Nicol=C3=B2=20Boschi?= <boschi1997@gmail.com>
Date: Mon, 17 Oct 2022 16:10:23 +0200
Subject: [PATCH] [misc] Move log 'Skip flushing because the pending flush is
 empty' to debug level (#471)

---
 .../apache/pulsar/io/jcloud/sink/BlobStoreAbstractSink.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/org/apache/pulsar/io/jcloud/sink/BlobStoreAbstractSink.java b/src/main/java/org/apache/pulsar/io/jcloud/sink/BlobStoreAbstractSink.java
index 8465de7f..b08a9a3f 100644
--- a/src/main/java/org/apache/pulsar/io/jcloud/sink/BlobStoreAbstractSink.java
+++ b/src/main/java/org/apache/pulsar/io/jcloud/sink/BlobStoreAbstractSink.java
@@ -203,12 +203,12 @@ private void flush() {
         }
 
         if (pendingFlushQueue.isEmpty()) {
-            log.info("Skip flushing, because the pending flush queue is empty ...");
+            log.debug("Skip flushing because the pending flush queue is empty...");
             return;
         }
 
         if (!isFlushRunning.compareAndSet(false, true)) {
-            log.info("Skip flushing, because there is an outstanding flush ...");
+            log.info("Skip flushing because there is an outstanding flush...");
             return;
         }