diff --git a/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreCleanFilesTest.java b/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreCleanFilesTest.java
index cf970e6dbd4282f20f2e8b2a3e1d00ebb820f2a0..b987cd385d9d6b6fe1eba33c6148aa4cab189874 100644
--- a/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreCleanFilesTest.java
+++ b/store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreCleanFilesTest.java
@@ -107,7 +107,7 @@ public class DefaultMessageStoreCleanFilesTest {
     @Test
     public void testDeleteExpiredFilesBySpaceFull() throws Exception {
         String deleteWhen = "04";
-        // the min value of diskMaxUsedSpaceRatio. make sure disk space usage is greater than 10%
+        // the min value of diskMaxUsedSpaceRatio.
         int diskMaxUsedSpaceRatio = 1;
         // used to ensure that automatic file deletion is not triggered
         double diskSpaceCleanForciblyRatio = 0.999D;
@@ -146,7 +146,7 @@ public class DefaultMessageStoreCleanFilesTest {
     @Test
     public void testDeleteFilesImmediatelyBySpaceFull() throws Exception {
         String deleteWhen = "04";
-        // the min value of diskMaxUsedSpaceRatio. make sure disk space usage is greater than 10%
+        // the min value of diskMaxUsedSpaceRatio.
         int diskMaxUsedSpaceRatio = 1;
         // make sure to trigger the automatic file deletion feature
         double diskSpaceCleanForciblyRatio = 0.01D;
@@ -304,8 +304,9 @@ public class DefaultMessageStoreCleanFilesTest {
             assertTrue(result != null && result.isOk());
         }
 
-        // wait for build consumer queue completion
-        Thread.sleep(100);
+        StoreTestUtil.waitCommitLogReput(messageStore);
+        StoreTestUtil.flushConsumeQueue(messageStore);
+        StoreTestUtil.flushConsumeIndex(messageStore);
     }
 
     private void expireFiles(MappedFileQueue commitLogQueue, int expireCount) {