diff --git a/src/java/org/apache/cassandra/journal/ActiveSegment.java b/src/java/org/apache/cassandra/journal/ActiveSegment.java
index a815d23199..1bee25a96f 100644
--- a/src/java/org/apache/cassandra/journal/ActiveSegment.java
+++ b/src/java/org/apache/cassandra/journal/ActiveSegment.java
@@ -183,6 +183,7 @@ final class ActiveSegment<K, V> extends Segment<K, V>
     {
         index.persist(descriptor);
         metadata.persist(descriptor);
+        syncedOffsets.fsync();
         SyncUtil.trySyncDir(descriptor.directory);
     }
 
diff --git a/src/java/org/apache/cassandra/journal/SyncedOffsets.java b/src/java/org/apache/cassandra/journal/SyncedOffsets.java
index cd05e6f8ac..8a89f72ad7 100644
--- a/src/java/org/apache/cassandra/journal/SyncedOffsets.java
+++ b/src/java/org/apache/cassandra/journal/SyncedOffsets.java
@@ -135,6 +135,7 @@ interface SyncedOffsets extends Closeable
             {
                 output.writeInt(offset);
                 output.writeInt((int) crc.getValue());
+                output.flush();
             }
             catch (IOException e)
             {