diff options
| author | Jon Marius Venstad <jonmv@users.noreply.github.com> | 2020-09-08 16:25:04 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-09-08 16:25:04 +0200 |
| commit | e04543f23050fb2adb941334000273dc616f3c95 (patch) | |
| tree | e930fd7a2dc4e9184adaffac36a242453f81b802 | |
| parent | 32b6bf08d84410130a9e3c7af18416cbc0e26652 (diff) | |
| parent | 8b8bf041c87088dde1d71b7e23a4d9881f37be8f (diff) | |
Merge pull request #14326 from vespa-engine/jonmv/flush-log-stream-every-64k-lines
Flush log stream every 64k lines as well
| -rw-r--r-- | container-core/src/main/java/com/yahoo/container/handler/LogReader.java | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/container-core/src/main/java/com/yahoo/container/handler/LogReader.java b/container-core/src/main/java/com/yahoo/container/handler/LogReader.java index 2884eb486ca..a304dc3c4ff 100644 --- a/container-core/src/main/java/com/yahoo/container/handler/LogReader.java +++ b/container-core/src/main/java/com/yahoo/container/handler/LogReader.java @@ -72,9 +72,12 @@ class LogReader { Iterator<LineWithTimestamp> lines = Iterators.mergeSorted(logLineIterators, Comparator.comparingDouble(LineWithTimestamp::timestamp)); + long linesWritten = 0; while (lines.hasNext()) { writer.write(lines.next().line()); writer.newLine(); + if ((++linesWritten & ((1 << 16) - 1)) == 0) + writer.flush(); } } catch (IOException e) { |