[druid] branch master updated: avoid logging pause message multiple times (#11375)

[xv...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

xvrl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git


The following commit(s) were added to refs/heads/master by this push:
     new c8b3f8c  avoid logging pause message multiple times (#11375)
c8b3f8c is described below

commit c8b3f8cc008b58c0138f8581aff95ff8a7511917
Author: Xavier Léauté <xv...@apache.org>
AuthorDate: Tue Jun 22 09:30:38 2021 -0700

    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.
---
 .../druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 @@ public abstract class SeekableStreamIndexTaskRunner<PartitionIdType, SequenceOff
         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();
         }
 

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org