[misc] Move log 'Skip flushing because the pending flush is empty' to…

… debug level (#471)
streamnative · Oct 19, 2022 · 29f2e0d · 29f2e0d
1 parent cf1c4e8
commit 29f2e0d
Showing 1 changed file with 2 additions and 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
@@ -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;
         }