diff options
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java')
-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 c9c6546711a..3569a28f563 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 @@ -3,6 +3,7 @@ package com.yahoo.search.logging; import com.yahoo.concurrent.DaemonThreadFactory; import java.io.IOException; +import java.time.Clock; import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledThreadPoolExecutor; @@ -25,7 +26,7 @@ public abstract class AbstractSpoolingLogger extends AbstractThreadedLogger impl protected final Spooler spooler; public AbstractSpoolingLogger() { - this(new Spooler()); + this(new Spooler(Clock.systemUTC())); } public AbstractSpoolingLogger(Spooler spooler) { @@ -35,6 +36,7 @@ public abstract class AbstractSpoolingLogger extends AbstractThreadedLogger impl public void run() { try { + spooler.switchFileIfNeeded(); spooler.processFiles(this::transport); } catch (IOException e) { e.printStackTrace(); |