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é <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
