diff --git a/src/mito2/src/engine/compaction_test.rs b/src/mito2/src/engine/compaction_test.rs index 09fc4e2935..d20226a307 100644 --- a/src/mito2/src/engine/compaction_test.rs +++ b/src/mito2/src/engine/compaction_test.rs @@ -532,8 +532,8 @@ async fn test_compaction_region_with_overlapping_delete_all_with_format(flat_for .unwrap(); // Flush 4 SSTs for compaction. put_and_flush(&engine, region_id, &column_schemas, 0..1200).await; // window 3600 - put_and_flush(&engine, region_id, &column_schemas, 0..2400).await; // window 3600 - put_and_flush(&engine, region_id, &column_schemas, 0..3600).await; // window 3600 + put_and_flush(&engine, region_id, &column_schemas, 1200..2400).await; // window 3600 + put_and_flush(&engine, region_id, &column_schemas, 2400..3600).await; // window 3600 delete_and_flush(&engine, region_id, &column_schemas, 0..10800).await; // window 10800 tokio::time::sleep(Duration::from_millis(2)).await; compact(&engine, region_id).await;