summaryrefslogtreecommitdiffstats
path: root/container-search/src
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2023-12-06 12:30:55 +0100
committerHarald Musum <musum@yahooinc.com>2023-12-06 12:30:55 +0100
commitf6b7eda4dd3a1189aab75bf463d9ec3ce8ebc934 (patch)
treef1b7173a6f2d62a8b10b0fcd6b4076720c99e2dd /container-search/src
parent851a7bb5e57a4521feec338bf5b4cc7e099b927b (diff)
Delay processing of files, subclasses might need to be constructed fully first
Diffstat (limited to 'container-search/src')
-rw-r--r--container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java b/container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java
index 041ad9f4ff1..1f57de22f55 100644
--- a/container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java
+++ b/container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java
@@ -23,6 +23,7 @@ public abstract class AbstractSpoolingLogger extends AbstractThreadedLogger impl
private final ScheduledExecutorService executorService;
protected final Spooler spooler;
+ @SuppressWarnings("unused") // Used by subclasses
public AbstractSpoolingLogger() {
this(new Spooler(Clock.systemUTC()));
}
@@ -30,7 +31,8 @@ public abstract class AbstractSpoolingLogger extends AbstractThreadedLogger impl
public AbstractSpoolingLogger(Spooler spooler) {
this.spooler = spooler;
this.executorService = new ScheduledThreadPoolExecutor(1, new DaemonThreadFactory("AbstractSpoolingLogger-send-"));
- executorService.scheduleWithFixedDelay(this, 0, 1L, TimeUnit.SECONDS);
+ // Delay some time before starting to process files, subclasses might need to be constructed fully first
+ this.executorService.scheduleWithFixedDelay(this, 5, 1L, TimeUnit.SECONDS);
}
public void run() {