diff --git a/src/java/org/apache/cassandra/journal/Journal.java b/src/java/org/apache/cassandra/journal/Journal.java
index c092363af7..50a3058ec9 100644
--- a/src/java/org/apache/cassandra/journal/Journal.java
+++ b/src/java/org/apache/cassandra/journal/Journal.java
@@ -198,6 +198,10 @@ public class Journal<K, V> implements Shutdownable
 
     public boolean isFlushed(RecordPointer recordPointer)
     {
+        Segment<K, V> current = currentSegment;
+        if (current.descriptor.timestamp == recordPointer.segment)
+            return current.isFlushed(recordPointer.position);
+
         return segments.get().isFlushed(recordPointer);
     }