diff --git a/src/blockstore/blockstore_flush.cpp b/src/blockstore/blockstore_flush.cpp
index 5496671f..2dc777e2 100644
--- a/src/blockstore/blockstore_flush.cpp
+++ b/src/blockstore/blockstore_flush.cpp
@@ -221,7 +221,7 @@ resume_1:
     }
     cur_version = cur_obj->get_writes()->version;
     // Find the range to compact
-    compact_lsn = bs->heap->get_completed_lsn();
+    compact_lsn = bs->heap->get_fsynced_lsn();
     bs->heap->get_compact_range(cur_obj, compact_lsn, &begin_wr, &end_wr);
     if (!begin_wr)
     {