commit c8b3f8cc008b58c0138f8581aff95ff8a7511917
author Xavier Léauté <xvrl@apache.org> Tue Jun 22 09:30:38 2021 -0700
committer GitHub <noreply@github.com> Tue Jun 22 09:30:38 2021 -0700
tree 63cbf79279a416c84d8132949686b031cd7630d7
parent f0b105ec63657643c85d82686ae1dea3e588a5f5

avoid logging pause message multiple times (#11375)

In some instances the ingestion thread could be woken up spuriously,
resulting in the "Received pause command..." log message getting logged
multiple times. This change ensures we only log it once the first time
the pause is requested.

indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java

diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java
index 6f0728d..ffede95 100644
--- a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java
+++ b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java
@@ -1279,8 +1279,8 @@
         status = Status.PAUSED;
         hasPaused.signalAll();
 
+        log.debug("Received pause command, pausing ingestion until resumed.");
         while (pauseRequested) {
-          log.debug("Received pause command, pausing ingestion until resumed.");
           shouldResume.await();
         }