diff --git a/logstash-core/src/main/java/org/logstash/ackedqueue/io/MmapPageIOV2.java b/logstash-core/src/main/java/org/logstash/ackedqueue/io/MmapPageIOV2.java index 2c8dd403a..ecb4ee170 100644 --- a/logstash-core/src/main/java/org/logstash/ackedqueue/io/MmapPageIOV2.java +++ b/logstash-core/src/main/java/org/logstash/ackedqueue/io/MmapPageIOV2.java @@ -190,6 +190,7 @@ public final class MmapPageIOV2 implements PageIO { } buffer.position(0); buffer.put(VERSION_TWO); + buffer.force(); this.head = 1; this.minSeqNum = 0L; this.elementCount = 0;