diff options
author | Harald Musum <musum@yahooinc.com> | 2023-12-06 12:30:55 +0100 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2023-12-06 12:30:55 +0100 |
commit | f6b7eda4dd3a1189aab75bf463d9ec3ce8ebc934 (patch) | |
tree | f1b7173a6f2d62a8b10b0fcd6b4076720c99e2dd /container-search | |
parent | 851a7bb5e57a4521feec338bf5b4cc7e099b927b (diff) |
Delay processing of files, subclasses might need to be constructed fully first
Diffstat (limited to 'container-search')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java | 4 |
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() { |